// 定义原子状态
const currentCompanyState = atom<Company | null>(null);
const companyContactsState = atom<Contact[]>([]);
const isLoadingState = atom<boolean>(false);

// 派生状态
const companyWithContactsState = atom((get) => {
  const company = get(currentCompanyState);
  const contacts = get(companyContactsState);
  return company ? { ...company, contacts } : null;
});

// 表单专用原子
const companyFormState = atomFamily((companyId: string) =>
  atom<CompanyFormData>({ /* 默认值 */ })
);

query GetCompanies($first: Int!, $after: String) {
  companies(first: $first, after: $after) {
    edges {
      node {
        id
        name
        domain
        industry
        employees
        createdAt
        contacts {
          edges {
            node {
              id
              name
              email
            }
          }
        }
      }
    }
    pageInfo {
      hasNextPage
      endCursor
    }
  }
}

// JWT Payload 结构
interface JWTPayload {
  sub: string;           // 用户 ID
  workspaceId: string;   // 工作空间 ID
  role: Role;            // 用户角色
  type: 'access' | 'refresh';
}

// 生成 Access Token
const accessToken = jwt.sign(
  {
    sub: user.id,
    workspaceId: workspace.id,
    role: user.role,
    type: 'access',
  },
  process.env.JWT_SECRET,
  { expiresIn: '15m' }
);

// 生成 Refresh Token
const refreshToken = jwt.sign(
  { sub: user.id, type: 'refresh' },
  process.env.JWT_REFRESH_SECRET,
  { expiresIn: '7d' }
);

# 复制环境变量模板
cp twenty-server/.env.example twenty-server/.env
cp twenty-front/.env.example twenty-front/.env

# 编辑服务器环境变量
vim twenty-server/.env

# 关键配置项：
# - POSTGRES_HOST=localhost
# - POSTGRES_USER=postgres
# - POSTGRES_PASSWORD=your_password
# - POSTGRES_DB=twenty
# - REDIS_HOST=localhost
# - FRONTEND_URL=http://localhost:3000

# 克隆仓库
git clone https://github.com/twentyhq/twenty.git
cd twenty

# 复制并编辑环境变量
cp twenty-docker/.env.example twenty-docker/.env
vim twenty-docker/.env

# 启动所有服务
cd twenty-docker
docker-compose up -d

# 查看服务状态
docker-compose ps

# 查看日志
docker-compose logs -f twenty-server

# 安装 Railway CLI
npm install -g @railway/cli

# 登录
railway login

# 初始化项目
railway init

# 添加 PostgreSQL
railway add

# 部署
railway up

// apollo-client.ts
import { ApolloClient, InMemoryCache, createHttpLink } from '@apollo/client';

const httpLink = createHttpLink({
  uri: 'http://localhost:3001/graphql',
  headers: {
    Authorization: `Bearer ${getAccessToken()}`,
  },
});

export const apolloClient = new ApolloClient({
  link: httpLink,
  cache: new InMemoryCache(),
  defaultOptions: {
    watchQuery: {
      fetchPolicy: 'cache-and-network',
    },
  },
});

// 创建 Webhook
const webhook = await api.webhooks.create({
  name: 'My CRM Webhook',
  url: 'https://my-app.example.com/webhook',
  events: [
    'company.created',
    'company.updated',
    'deal.stage_changed',
    'contact.created',
  ],
  secret: 'my-webhook-secret',
});

// webhook-handler.ts
import crypto from 'crypto';

function verifySignature(payload: string, signature: string, secret: string): boolean {
  const expected = crypto
    .createHmac('sha256', secret)
    .update(payload)
    .digest('hex');
  return crypto.timingSafeEqual(
    Buffer.from(signature),
    Buffer.from(expected)
  );
}

app.post('/webhook', (req, res) => {
  const signature = req.headers['x-twenty-signature'] as string;
  const isValid = verifySignature(
    JSON.stringify(req.body),
    signature,
    process.env.WEBHOOK_SECRET
  );

  if (!isValid) {
    return res.status(401).send('Invalid signature');
  }

  const { event, data } = req.body;

  switch (event) {
    case 'company.created':
      handleNewCompany(data);
      break;
    case 'deal.stage_changed':
      handleDealStageChange(data);
      break;
  }

  res.status(200).send('OK');
});

// 创建公司
const company = await client.companies.create({
  name: 'Acme Corp',
  domain: 'acme.com',
  industry: 'Technology',
});

// 创建联系人并关联公司
const contact = await client.contacts.create({
  name: 'John Doe',
  email: 'john@acme.com',
  companyId: company.id,
  jobTitle: 'CTO',
});

// 创建交易
const deal = await client.deals.create({
  name: 'Enterprise License',
  amount: 50000,
  stage: 'proposal',
  companyId: company.id,
  contactId: contact.id,
  expectedCloseDate: '2026-06-30',
});

// 查询数据
const companies = await client.companies.findMany({
  filter: { industry: { equals: 'Technology' } },
  orderBy: { createdAt: 'desc' },
  limit: 20,
});

// 销售代表角色 - 数据权限
const salesRepPermissions = {
  company: {
    read: 'own',     // 只能看自己的客户
    write: 'own',    // 只能编辑自己的客户
    delete: 'none', // 禁止删除
  },
  contact: {
    read: 'own',
    write: 'own',
    delete: 'none',
  },
  deal: {
    read: 'all',     // 需要看所有人的交易便于协作
    write: 'own',   // 只能编辑自己的交易
    delete: 'none',  // 禁止删除
  },
};

// ❌ 错误：可能导致状态更新触发自身
{
  trigger: { type: 'record.updated', field: 'status' },
  actions: [
    { type: 'update_record', field: 'lastUpdated', value: 'now' }
  ]
}

// ✅ 正确：使用条件防止循环
{
  trigger: { type: 'record.updated', field: 'status' },
  conditions: [
    { field: 'status', operator: 'equals', value: 'closed' }
  ],
  actions: [
    { type: 'send_notification', message: '交易已成交！' }
  ]
}

# 1. 创建模块目录
mkdir -p src/core/my-custom-module

# 2. 创建文件
touch src/core/my-custom-module/my-custom-module.entity.ts
touch src/core/my-custom-module/my-custom-module.service.ts
touch src/core/my-custom-module/my-custom-module.resolver.ts

# 3. 在 core.module.ts 中注册
@Module({
  imports: [
    MyCustomModuleModule,
  ],
  ...
})
export class CoreModule {}

import { TwentyClient } from 'twenty-sdk';

const client = new TwentyClient({
  baseUrl: 'https://your-twenty.com',
  apiKey: 'your-api-key',
});

// 批量导入函数
async function importContacts(contacts: ContactData[]) {
  const batchSize = 50;
  for (let i = 0; i < contacts.length; i += batchSize) {
    const batch = contacts.slice(i, i + batchSize);
    await Promise.all(
      batch.map(contact => client.contacts.create(contact))
    );
    console.log(`Imported ${Math.min(i + batchSize, contacts.length)}/${contacts.length}`);
  }
}