GitHub ActionsとBunで構築したSlackアーカイブシステム

// src/services/execution-mode.ts での実装例
export class ExecutionModeDetector {
  async detectChannelMode(
    channelId: string,
    timezone: string,
  ): Promise<ArchiveExecutionMode> {
    // 過去365日間のアーカイブファイルをチェック
    const hasExistingArchives = await this.checkExistingArchives(channelId);
    
    if (hasExistingArchives) {
      // 前日の日付範囲を計算
      const dateRange = calculatePreviousDayRange(timezone);
      return { type: 'daily', channelId, dateRange };
    } else {
      return { type: 'initial', channelId };
    }
  }
}

{
  "ts": "1704067200.123456",
  "user": "U1234567890",
  "text": "GitHub Actionsでのアーカイブシステムについて議論しましょう",
  "thread_ts": null,
  "replies": []
}

# TSVファイルでの簡単な検索例
grep "GitHub Actions" archives/C034RPY14BX/2024/05/*.tsv
awk -F'\t' '$3=="tomokisun" {print $4}' archives/C034RPY14BX/2024/05/C034RPY14BX_2024-05-01.tsv

// src/services/tsv-writer.ts
function escapeText(text: string): string {
  return text
    .replace(/\n/g, '\\n')    // 改行
    .replace(/\t/g, '\\t')    // タブ
    .replace(/\r/g, '\\r');   // キャリッジリターン
}

// src/services/slack-client.ts
export class SlackClient {
  private async withRetry<T>(
    operation: () => Promise<T>,
    maxRetries: number = 3,
    baseDelay: number = 1000,
  ): Promise<T> {
    for (let attempt = 1; attempt <= maxRetries; attempt++) {
      try {
        await this.delay(this.minRequestInterval); // 最小間隔の確保
        return await operation();
      } catch (error) {
        if (this.isRateLimitError(error) && attempt < maxRetries) {
          const delay = baseDelay * Math.pow(2, attempt - 1); // エクスポネンシャルバックオフ
          await this.delay(delay);
          continue;
        }
        throw error;
      }
    }
  }
}

// src/services/user-fetcher.ts
export class UserFetcher {
  private userCache = new Map<string, SlackUser>();
 
  async getUser(userId: string): Promise<SlackUser> {
    if (this.userCache.has(userId)) {
      return this.userCache.get(userId)!;
    }
 
    const user = await this.fetchUserFromAPI(userId);
    this.userCache.set(userId, user);
    return user;
  }
}

# .github/workflows/archive.yml
name: Archive Slack Messages
 
on:
  schedule:
    # Run at 00:00 JST (15:00 UTC) every day
    - cron: '0 15 * * *'
  workflow_dispatch:
    # Allow manual trigger for testing
 
jobs:
  prepare:
    runs-on: ubuntu-latest
    outputs:
      channels: ${{ steps.set-channels.outputs.channels }}
    steps:
      - name: Set up channel matrix
        run: |
          channels_json=$(yq -o=json -I=0 '.channels' .github/slack-channels.yml | jq -c .)
          echo "channels=$channels_json" >> $GITHUB_OUTPUT
 
  archive:
    needs: prepare
    strategy:
      matrix:
        channel: ${{ fromJson(needs.prepare.outputs.channels) }}
      max-parallel: 5 # レート制限対策
    steps:
      - uses: oven-sh/setup-bun@v2
        with:
          bun-version: latest
      
      - name: Run archive script
        uses: nick-fields/retry@v3
        with:
          timeout_minutes: 60
          max_attempts: 3
          command: bun run src/index.ts
        env:
          SLACK_BOT_TOKEN: ${{ secrets.SLACK_BOT_TOKEN }}
          SLACK_CHANNEL: ${{ matrix.channel }}

# .github/slack-channels.yml
channels:
  - C034RPY14BX # general
  - C03V8SFC005 # history
  - C06UNC9G2HW # surf
  - C08C4CVA1J4 # ｼｭｯｼｬﾌﾞ
  - C08GY86P1TQ # ﾆｯﾎﾟｳ

strategy:
  fail-fast: false # 1つが失敗しても他を継続
  matrix:
    channel: ${{ fromJson(needs.prepare.outputs.channels) }}
  max-parallel: 5 # レート制限対策
 
continue-on-error: true # 個別チャンネルの失敗を許容

// src/utils/file-system.ts
export async function writeFileAtomically(
  filePath: string,
  content: string,
): Promise<void> {
  const tempPath = `${filePath}.tmp`;
  await Bun.write(tempPath, content);
  await fs.rename(tempPath, filePath); // アトミックな書き込み
}

- name: Notify on failure
  if: failure()
  uses: actions/upload-artifact@v4
  with:
    name: slack-archives-${{ matrix.channel }}-${{ github.run_id }}
    path: archives/${{ matrix.channel }}/
    retention-days: 7

timestamp	user_id	user_name	text	thread_ts	reply_count
1704067200.123456	U1234567890	tomokisun	GitHub Actionsでのアーカイブシステムについて議論しましょう		3
1704067260.789012	U0987654321	satopon	TypeScriptで実装する予定ですか？	1704067200.123456	0
1704067320.456789	U1234567890	tomokisun	はい、型安全性を重視してTypeScriptで進める予定です	1704067200.123456	0