Phase 2-1: グループ管理Mutationの実装

[takaokouji]

目的

グループの作成、参加、検索機能を実装します（createGroup, joinGroup, listGroupsByDomain）。Domain概念に対応し、グローバルIPベースのスコープ管理を実現します。

タスク

listGroupsByDomain Queryリゾルバー（スキャン機能）

• DynamoDB DataSourceの定義
• リクエストハンドラー (JS) の実装
  • Domain自動取得: ctx.identity.sourceIp または ctx.args.domain
  • DynamoDB Query: PK = DOMAIN#{domain}, SK begins_with GROUP#
• レスポンスハンドラーの実装
  • Group型の配列を返却
• Resolverの登録

createGroup Mutationリゾルバー

• リクエストハンドラー (JS) の実装
  • Domain自動取得: ctx.args.domain または ctx.identity.sourceIp
  • グループID生成: util.autoId()
  • fullId生成: {group_id}@{domain}
  • Groupメタデータの作成
    • PK: DOMAIN#{domain}, SK: GROUP#{group_id}#METADATA
    • 属性: id, domain, fullId, name, hostId, createdAt
• レスポンスハンドラーの実装
  • Group型を返却
• Resolverの登録

joinGroup Mutationリゾルバー

• リクエストハンドラー (JS) の実装
  • Nodeの追加
    • PK: DOMAIN#{domain}, SK: GROUP#{group_id}#NODE#{node_id}
  • Node所属情報の作成
    • PK: NODE#{node_id}, SK: METADATA
    • 属性: nodeId, groupId, domain
  • TransactWriteItemsでアトミックに実行
• レスポンスハンドラーの実装
  • Node型を返却
• Resolverの登録

テスト

• listGroupsByDomain動作確認
  • Domain指定あり
  • Domain指定なし（グローバルIP自動取得）
• createGroup動作確認
  • fullIdの正しい生成
• joinGroup動作確認
• エラーハンドリング確認

成果物

• JSリゾルバーファイル
  • js/resolvers/Query.listGroupsByDomain.req.js
  • js/resolvers/Query.listGroupsByDomain.res.js
  • js/resolvers/Mutation.createGroup.req.js
  • js/resolvers/Mutation.createGroup.res.js
  • js/resolvers/Mutation.joinGroup.req.js
  • js/resolvers/Mutation.joinGroup.res.js
• CDK Resolver定義コード

リゾルバー実装例

listGroupsByDomain リクエスト

// js/resolvers/Query.listGroupsByDomain.req.js

function request(ctx) {
  // Domain決定: 引数 > ソースIP
  const sourceIp = ctx.identity.sourceIp[0];
  const domain = ctx.args.domain || sourceIp;
  
  return {
    operation: 'Query',
    query: {
      expression: 'pk = :pk AND begins_with(sk, :sk_prefix)',
      expressionValues: {
        ':pk': { S: `DOMAIN#${domain}` },
        ':sk_prefix': { S: 'GROUP#' }
      }
    }
  };
}

listGroupsByDomain レスポンス

// js/resolvers/Query.listGroupsByDomain.res.js

function response(ctx) {
  if (ctx.error) {
    util.error(ctx.error.message, ctx.error.type);
  }
  
  // DynamoDBアイテムをGroup型に変換
  return ctx.result.items
    .filter(item => item.sk.S.endsWith('#METADATA'))
    .map(item => ({
      id: item.id.S,
      domain: item.domain.S,
      fullId: item.fullId.S,
      name: item.name.S,
      hostId: item.hostId.S,
      createdAt: item.createdAt.S
    }));
}

createGroup リクエスト

// js/resolvers/Mutation.createGroup.req.js

function request(ctx) {
  const { name, hostId, domain } = ctx.args;
  
  // Domain決定: 引数 > ソースIP
  const sourceIp = ctx.identity.sourceIp[0];
  const actualDomain = domain || sourceIp;
  
  // Domain文字列のバリデーション（最大256文字）
  if (actualDomain.length > 256) {
    util.error('Domain must be 256 characters or less', 'ValidationError');
  }
  
  // グループID生成
  const groupId = util.autoId();
  const fullId = `${groupId}@${actualDomain}`;
  const now = util.time.nowISO8601();
  
  return {
    operation: 'PutItem',
    key: {
      pk: { S: `DOMAIN#${actualDomain}` },
      sk: { S: `GROUP#${groupId}#METADATA` }
    },
    attributeValues: {
      id: { S: groupId },
      domain: { S: actualDomain },
      fullId: { S: fullId },
      name: { S: name },
      hostId: { S: hostId },
      createdAt: { S: now },
      // GSI用
      gsi_pk: { S: `GROUP#${groupId}` },
      gsi_sk: { S: `DOMAIN#${actualDomain}` }
    }
  };
}

createGroup レスポンス

// js/resolvers/Mutation.createGroup.res.js

function response(ctx) {
  if (ctx.error) {
    util.error(ctx.error.message, ctx.error.type);
  }
  
  // 入力引数とソースIPからGroup型を構築
  const sourceIp = ctx.identity.sourceIp[0];
  const domain = ctx.args.domain || sourceIp;
  const groupId = ctx.result.Attributes.id.S;
  
  return {
    id: groupId,
    domain: domain,
    fullId: `${groupId}@${domain}`,
    name: ctx.args.name,
    hostId: ctx.args.hostId,
    createdAt: ctx.result.Attributes.createdAt.S
  };
}

joinGroup リクエスト（TransactWriteItems）

// js/resolvers/Mutation.joinGroup.req.js

function request(ctx) {
  const { groupId, domain, nodeId } = ctx.args;
  const now = util.time.nowISO8601();
  
  return {
    operation: 'TransactWriteItems',
    transactItems: [
      // Node情報の追加
      {
        table: 'MeshV2Table',
        operation: 'PutItem',
        key: {
          pk: { S: `DOMAIN#${domain}` },
          sk: { S: `GROUP#${groupId}#NODE#${nodeId}` }
        },
        attributeValues: {
          nodeId: { S: nodeId },
          groupId: { S: groupId },
          domain: { S: domain },
          name: { S: `Node ${nodeId}` },
          data: { L: [] },
          timestamp: { S: now }
        }
      },
      // Node所属情報の作成
      {
        table: 'MeshV2Table',
        operation: 'PutItem',
        key: {
          pk: { S: `NODE#${nodeId}` },
          sk: { S: 'METADATA' }
        },
        attributeValues: {
          nodeId: { S: nodeId },
          groupId: { S: groupId },
          domain: { S: domain }
        }
      }
    ]
  };
}

関連

• EPIC Issue: EPIC: Mesh v2 拡張機能の実装 #444
• Phase: 2 (バックエンドロジック)
• 依存: Phase 1-3: AppSync GraphQL APIとスキーマの実装 #448 (Phase 1-3)
• 更新: Domain概念の導入、listGroupsByDomain追加（Phase 0レビューフィードバック）

🤖 Generated with Claude Code

Co-Authored-By: Claude noreply@anthropic.com

[takaokouji]

Phase 2-1完了

グループ管理Mutationの実装が完了しました。

実装内容

1. listGroupsByDomain Query Resolver

機能: Domain内のグループ一覧を取得

実装ファイル: js/resolvers/Query.listGroupsByDomain.js

処理フロー:

1. Domain決定: ctx.args.domain || ctx.identity.sourceIp[0]
2. DynamoDB Query: PK = DOMAIN#{domain}, SK begins_with GROUP#
3. METADATA サフィックスを持つアイテムのみフィルタ
4. Group型の配列を返却

2. createGroup Mutation Resolver

機能: グループを作成し、Domainに対応したメタデータを保存

実装ファイル: js/resolvers/Mutation.createGroup.js

処理フロー:

1. Domain決定: ctx.args.domain || ctx.identity.sourceIp[0]
2. Domainバリデーション（最大256文字）
3. グループID生成: util.autoId()
4. fullId生成: {groupId}@{domain}
5. DynamoDB PutItem:
   • PK: DOMAIN#{domain}
   • SK: GROUP#{groupId}#METADATA
   • GSI: gsi_pk=GROUP#{groupId}, gsi_sk=DOMAIN#{domain}

3. joinGroup Mutation Resolver

機能: ノードをグループに参加させる（アトミック実行）

実装ファイル: js/resolvers/Mutation.joinGroup.js

処理フロー:

1. TransactWriteItems で2つのアイテムをアトミックに作成:
   • グループ内のノード情報: PK=DOMAIN#{domain}, SK=GROUP#{groupId}#NODE#{nodeId}
   • ノードの所属情報（逆引き用）: PK=NODE#{nodeId}, SK=METADATA

DynamoDBデータモデル

Groups (グループメタデータ):
  PK: DOMAIN#{domain}
  SK: GROUP#{groupId}#METADATA
  Attributes: id, domain, fullId, name, hostId, createdAt
  GSI: gsi_pk=GROUP#{groupId}, gsi_sk=DOMAIN#{domain}

Nodes (グループ内のノード):
  PK: DOMAIN#{domain}
  SK: GROUP#{groupId}#NODE#{nodeId}
  Attributes: id, nodeId, groupId, domain, name, joinedAt

Node Metadata (ノード所属情報):
  PK: NODE#{nodeId}
  SK: METADATA
  Attributes: id, nodeId, groupId, domain, name, joinedAt

CDK Stack更新

追加されたリソース:

• ListGroupsByDomainResolver - Query resolver
• CreateGroupResolver - Mutation resolver
• JoinGroupResolver - Mutation resolver

Runtime: APPSYNC_JS 1.0.0

DataSource: MeshV2TableDataSource (DynamoDB)

Domain自動検出の実装

// リゾルバーでのDomain決定ロジック
const sourceIp = ctx.identity.sourceIp[0]; // 配列の最初の要素
const domain = ctx.args.domain || sourceIp;

• domain引数が指定されていればそれを使用
• 未指定の場合はソースIPを自動取得
• これにより、同じグローバルIPからアクセスするユーザー間でグループを共有可能

確認方法

cd infra/mesh-v2

# TypeScriptコンパイル
npm run build

# CloudFormationテンプレート生成
npx cdk synth

# デプロイ
npx cdk deploy

デプロイ後、AppSync Consoleで以下のクエリをテスト可能:

# グループ作成（Domain自動検出）
mutation {
  createGroup(name: "テストグループ", hostId: "host-001") {
    id
    domain
    fullId
    name
    hostId
    createdAt
  }
}

# グループ一覧取得（Domain自動検出）
query {
  listGroupsByDomain {
    id
    domain
    fullId
    name
    hostId
    createdAt
  }
}

# グループ参加
mutation {
  joinGroup(
    groupId: "生成されたgroupId"
    domain: "自動検出されたdomain"
    nodeId: "node-001"
  ) {
    id
    name
    groupId
    domain
  }
}

コミット

• mesh-v2: smalruby/mesh-v2@f844773
• smalruby3-develop: smalruby/smalruby3-develop@4167deb

次のステップ

Phase 2-2以降で以下を実装予定:

• データ送信 (reportDataByNode)
• イベント発火 (fireEventByNode)
• Subscription実装
• その他のQuery/Mutation

🤖 Generated with Claude Code

Co-Authored-By: Claude Sonnet 4.5 noreply@anthropic.com