1
'use server';
2
import ky, { type Options } from 'ky';
3
import { cookies, headers } from 'next/headers';
4
import 'server-only';
5
import checkApiVersion from '../check-api-version';
6
const original = ky.create({
7
  credentials: 'omit',
8
  fetch: (...args) => fetch(...args),
9
  hooks: {
10
    beforeRequest: [
11
      async request => {
12
        const cookieStore = cookies();
13
        const header = headers();
14
        const accessToken =
15
          process.env.NEXT_PUBLIC_DEV_TOKEN ||
16
          cookieStore.get('access_token')?.value;
17
        const mixpanelDistinctId = cookieStore.get('mp_distinct_id')?.value;
18
        const swimlanes = header.get('swimlanes') || '';
19
        const userAgent = header.get('user-agent') || '';
20
        const requestId = header.get('X-Request-Id') || '';
21
        if (accessToken) {
22
          request.headers.set('Authorization', `Bearer ${accessToken}`);
23
        }
24
        if (mixpanelDistinctId) {
25
          request.headers.set('X-WB-User-ID', mixpanelDistinctId);
26
        }
27
        if (userAgent) {
28
          request.headers.set('user-agent', userAgent);
29
        }
30
        if (swimlanes) {
31
          request.headers.set('swimlanes', swimlanes);
32
        }
33
        if (requestId) {
34
          request.headers.set('X-Request-Id', requestId);
35
        }
36
      },
37
    ],
38
  },
39
});
40
const Get = <T = unknown>(url: string, options?: Options): Promise<T> => {
41
  return original.get(checkApiVersion(url), options).json<T>();
42
};
43
const Post = <T = unknown>(url: string, options?: Options): Promise<T> => {
44
  return original.post(checkApiVersion(url), options).json<T>();
45
};
46
const Put = <T = unknown>(url: string, options?: Options): Promise<T> => {
47
  return original.put(checkApiVersion(url), options).json<T>();
48
};
49
const Delete = <T = unknown>(url: string, options?: Options): Promise<T> => {
50
  return original.delete(checkApiVersion(url), options).json<T>();
51
};
52
export { Delete, Get, Post, Put };