# NestJS SDK

`@cohorly/nest` is a standard NestJS dynamic module (`forRoot` / `forRootAsync`) plus an injectable `CohorlyService` wrapping `@cohorly/node`, with an automatic final flush on application shutdown. Supports `@nestjs/common` ^10 and ^11.

## Install

```bash
pnpm add @cohorly/nest
```

## Register the module

```typescript
// app.module.ts
import { Module } from "@nestjs/common";
import { CohorlyModule } from "@cohorly/nest";

@Module({
  imports: [
    CohorlyModule.forRoot({
      token: process.env.COHORLY_TOKEN!,
      host: "https://cohorly-service.velloalabs.com",
      isGlobal: true, // inject CohorlyService anywhere without re-importing
    }),
  ],
})
export class AppModule {}
```

## Inject the service

```typescript
import { Injectable } from "@nestjs/common";
import { CohorlyService } from "@cohorly/nest";

@Injectable()
export class SignupService {
  constructor(private readonly cohorly: CohorlyService) {}

  async signUp(userId: string, email: string) {
    this.cohorly.track("signed_up", { distinct_id: userId, method: "email" });
    this.cohorly.people.set(userId, { $email: email, plan: "free" });
  }
}
```

`CohorlyService` exposes the full mixpanel-node-style
surface: `track`, `trackBatch`,
`import`, `importBatch`, `people.*`,
`alias`, `flush`, and the raw client at
`service.client`.

## Async configuration

```typescript
import { ConfigModule, ConfigService } from "@nestjs/config";
import { CohorlyModule } from "@cohorly/nest";

CohorlyModule.forRootAsync({
  imports: [ConfigModule],
  inject: [ConfigService],
  isGlobal: true,
  useFactory: (config: ConfigService) => ({
    token: config.getOrThrow("COHORLY_TOKEN"),
    host: config.get("COHORLY_HOST") ?? "https://cohorly-service.velloalabs.com",
  }),
});
```

All `@cohorly/node` config options are accepted
(`host`, `flushIntervalMs`,
`batchSize`, `debug`, `maxQueueSize`,
`maxRetryDelayMs`), plus `token` (required) and
`isGlobal`.

## Graceful shutdown

`CohorlyService` implements
`OnApplicationShutdown`: when the Nest application closes
it stops the SDK's flush timer and performs a final flush. To
also cover process signals, enable Nest's shutdown hooks:

```typescript
const app = await NestFactory.create(AppModule);
app.enableShutdownHooks();
```