Quick Start

npm install @stackshift-cloud/jobs@^0.2.0

go get github.com/stackshiftCloud/jobs-go@v0.2.0

import { StackShift } from '@stackshift-cloud/jobs'

export const stackshift = new StackShift({
  apiKey: process.env.STACKSHIFT_API_KEY!,
  baseUrl: process.env.STACKSHIFT_API_URL,
})

import stackshift "github.com/stackshiftCloud/jobs-go"

client, err := stackshift.New(stackshift.Options{
  APIKey: os.Getenv("STACKSHIFT_API_KEY"),
  BaseURL: os.Getenv("STACKSHIFT_API_URL"),
  Verification: &stackshift.InvocationVerification{
    PublicKey: os.Getenv("STACKSHIFT_JOBS_PUBLIC_KEY"),
    UserID: os.Getenv("STACKSHIFT_ACCOUNT_ID"),
  },
})

import { stackshift } from '@/lib/stackshift'

export async function POST(request: Request) {
  const body = await request.json()

  const run = await stackshift.queue('emails').enqueue(
    'sendVerificationEmail',
    { userId: body.userId, email: body.email },
    {
      idempotencyKey: `verify:${body.userId}`,
      idempotencyTtl: '30d',
      handlerUrl: `${process.env.APP_URL}/api/stackshift/jobs`,
    }
  )

  return Response.json({ runId: run.id, status: run.status })
}

func signupHandler(w http.ResponseWriter, r *http.Request) {
  var body struct {
    UserID string `json:"userId"`
    Email  string `json:"email"`
  }
  _ = json.NewDecoder(r.Body).Decode(&body)

  run, err := client.Queue("emails").Enqueue(r.Context(),
    "sendVerificationEmail",
    map[string]any{"userId": body.UserID, "email": body.Email},
    &stackshift.EnqueueOptions{
      IdempotencyKey: "verify:" + body.UserID,
      IdempotencyTTL: "30d",
      HandlerURL: os.Getenv("APP_URL") + "/stackshift/jobs",
    },
  )
  if err != nil {
    http.Error(w, err.Error(), http.StatusBadGateway)
    return
  }

  _ = json.NewEncoder(w).Encode(map[string]any{
    "runId": run.ID,
    "status": run.Status,
  })
}

import { stackshift } from '@/lib/stackshift'
import { sendEmail } from '@/lib/email'

stackshift.job<{ userId: string; email: string }>('sendVerificationEmail', async ({ payload, step }) => {
  await step.run('send-email', async () => {
    await sendEmail({
      to: payload.email,
      subject: 'Verify your email',
      template: { name: "verify", userId: payload.userId },
    })

    return { sent: true }
  })

  return { ok: true }
})

client.Job("sendVerificationEmail", func(ctx context.Context, job stackshift.JobContext) (any, error) {
  var payload struct {
    UserID string `json:"userId"`
    Email  string `json:"email"`
  }
  if err := json.Unmarshal(job.Payload, &payload); err != nil {
    return nil, err
  }

  _, err := job.Step.Run(ctx, "send-email", func(ctx context.Context, invocation stackshift.HandlerInvocation) (any, error) {
    return map[string]any{"sent": true}, sendEmail(payload.Email, payload.UserID)
  })
  if err != nil {
    return nil, err
  }

  return map[string]any{"ok": true}, nil
})

import '@/jobs'
import { stackshift } from '@/lib/stackshift'

export async function POST(request: Request) {
  return stackshift.handleRequest(request, {
    publicKey: process.env.STACKSHIFT_JOBS_PUBLIC_KEY!,
    userId: process.env.STACKSHIFT_ACCOUNT_ID!,
  })
}

mux := http.NewServeMux()
mux.Handle("/stackshift/jobs", client.HTTPHandler())

if err := http.ListenAndServe(":8080", mux); err != nil {
  log.Fatal(err)
}