zouyangxiaohao111/javaclawbot/feishu-integration-developer

feishu-integration/
├── src/
│   ├── config/
│   │   ├── feishu.ts              # Feishu app configuration
│   │   └── env.ts                 # Environment variable management
│   ├── auth/
│   │   ├── token-manager.ts       # Token retrieval and caching
│   │   └── event-verify.ts        # Event subscription verification
│   ├── bot/
│   │   ├── command-handler.ts     # Bot command handler
│   │   ├── message-sender.ts      # Message sending wrapper
│   │   └── card-builder.ts        # Message card builder
│   ├── approval/
│   │   ├── approval-define.ts     # Approval definition management
│   │   ├── approval-instance.ts   # Approval instance operations
│   │   └── approval-callback.ts   # Approval event callbacks
│   ├── bitable/
│   │   ├── table-client.ts        # Bitable CRUD operations
│   │   └── sync-service.ts        # Data synchronization service
│   ├── sso/
│   │   ├── oauth-handler.ts       # OAuth authorization flow
│   │   └── user-sync.ts           # User info synchronization
│   ├── webhook/
│   │   ├── event-dispatcher.ts    # Event dispatcher
│   │   └── handlers/              # Event handlers by type
│   └── utils/
│       ├── http-client.ts         # HTTP request wrapper
│       ├── logger.ts              # Logging utility
│       └── retry.ts               # Retry mechanism
├── tests/
├── docker-compose.yml
└── package.json

// src/auth/token-manager.ts
import * as lark from '@larksuiteoapi/node-sdk';
const client = new lark.Client({
  appId: process.env.FEISHU_APP_ID!,
  appSecret: process.env.FEISHU_APP_SECRET!,
  disableTokenCache: false, // SDK built-in caching
});
export { client };
// Manual token management scenario (when not using the SDK)
class TokenManager {
  private token: string = '';
  private expireAt: number = 0;
  async getTenantAccessToken(): Promise<string> {
    if (this.token && Date.now() < this.expireAt) {
      return this.token;
    }
    const resp = await fetch(
      'https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal',
      {
        method: 'POST',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({
          app_id: process.env.FEISHU_APP_ID,
          app_secret: process.env.FEISHU_APP_SECRET,
        }),
      }
    );
    const data = await resp.json();
    if (data.code !== 0) {
      throw new Error(`Failed to obtain token: ${data.msg}`);
    }
    this.token = data.tenant_access_token;
    // Expire 5 minutes early to avoid boundary issues
    this.expireAt = Date.now() + (data.expire - 300) * 1000;
    return this.token;
  }
}
export const tokenManager = new TokenManager();

// src/bot/card-builder.ts
interface CardAction {
  tag: string;
  text: { tag: string; content: string };
  type: string;
  value: Record<string, string>;
}
// Build an approval notification card
function buildApprovalCard(params: {
  title: string;
  applicant: string;
  reason: string;
  amount: string;
  instanceId: string;
}): object {
  return {
    config: { wide_screen_mode: true },
    header: {
      title: { tag: 'plain_text', content: params.title },
      template: 'orange',
    },
    elements: [
      {
        tag: 'div',
        fields: [
          {
            is_short: true,
            text: { tag: 'lark_md', content: `**Applicant**\n${params.applicant}` },
          },
          {
            is_short: true,
            text: { tag: 'lark_md', content: `**Amount**\n¥${params.amount}` },
          },
        ],
      },
      {
        tag: 'div',
        text: { tag: 'lark_md', content: `**Reason**\n${params.reason}` },
      },
      { tag: 'hr' },
      {
        tag: 'action',
        actions: [
          {
            tag: 'button',
            text: { tag: 'plain_text', content: 'Approve' },
            type: 'primary',
            value: { action: 'approve', instance_id: params.instanceId },
          },
          {
            tag: 'button',
            text: { tag: 'plain_text', content: 'Reject' },
            type: 'danger',
            value: { action: 'reject', instance_id: params.instanceId },
          },
          {
            tag: 'button',
            text: { tag: 'plain_text', content: 'View Details' },
            type: 'default',
            url: `https://your-domain.com/approval/${params.instanceId}`,
          },
        ],
      },
    ],
  };
}
// Send a message card
async function sendCardMessage(
  client: any,
  receiveId: string,
  receiveIdType: 'open_id' | 'chat_id' | 'user_id',
  card: object
): Promise<string> {
  const resp = await client.im.message.create({
    params: { receive_id_type: receiveIdType },
    data: {
      receive_id: receiveId,
      msg_type: 'interactive',
      content: JSON.stringify(card),
    },
  });
  if (resp.code !== 0) {
    throw new Error(`Failed to send card: ${resp.msg}`);
  }
  return resp.data!.message_id;
}

// src/webhook/event-dispatcher.ts
import * as lark from '@larksuiteoapi/node-sdk';
import express from 'express';
const app = express();
const eventDispatcher = new lark.EventDispatcher({
  encryptKey: process.env.FEISHU_ENCRYPT_KEY || '',
  verificationToken: process.env.FEISHU_VERIFICATION_TOKEN || '',
});
// Listen for bot message received events
eventDispatcher.register({
  'im.message.receive_v1': async (data) => {
    const message = data.message;
    const chatId = message.chat_id;
    const content = JSON.parse(message.content);
    // Handle plain text messages
    if (message.message_type === 'text') {
      const text = content.text as string;
      await handleBotCommand(chatId, text);
    }
  },
});
// Listen for approval status changes
eventDispatcher.register({
  'approval.approval.updated_v4': async (data) => {
    const instanceId = data.approval_code;
    const status = data.status;
    if (status === 'APPROVED') {
      await onApprovalApproved(instanceId);
    } else if (status === 'REJECTED') {
      await onApprovalRejected(instanceId);
    }
  },
});
// Card action callback handler
const cardActionHandler = new lark.CardActionHandler({
  encryptKey: process.env.FEISHU_ENCRYPT_KEY || '',
  verificationToken: process.env.FEISHU_VERIFICATION_TOKEN || '',
}, async (data) => {
  const action = data.action.value;
  if (action.action === 'approve') {
    await processApproval(action.instance_id, true);
    // Return the updated card
    return {
      toast: { type: 'success', content: 'Approval granted' },
    };
  }
  return {};
});
app.use('/webhook/event', lark.adaptExpress(eventDispatcher));
app.use('/webhook/card', lark.adaptExpress(cardActionHandler));
app.listen(3000, () => console.log('Feishu event service started'));

// src/bitable/table-client.ts
class BitableClient {
  constructor(private client: any) {}