# for npm
npm install bundlesocial
# for pnpm
pnpm add bundlesocial
# for yarn
yarn add bundlesocial

import { BundleSocial } from 'bundlesocial';

// Get the API key from the bundle.social dashboard
const bundleSocial = new BundleSocial('YOUR_API_KEY');

const organization = await bundlesocial.organization.organizationGetOrganization();

const createdTeam = await bundlesocial.team.teamCreateTeam({
  requestBody: {
    name: 'Test Team',
    tier: 'FREE',
  },
});

const team = await bundlesocial.team.teamGetTeam({
  id: createdTeam?.id,
});

const response =
  await bundlesocial.socialAccount.socialAccountCreatePortalLink({
    requestBody: {
      teamId: team.id,
      socialAccountTypes: ['TIKTOK', 'FACEBOOK', 'INSTAGRAM'],
      redirectUrl: 'https://your-redirect-url.com',
      logoUrl: 'https://your-logo-url.com',
      userLogoUrl: 'https://your-user-logo-url.com',
      userName: 'Your User Name',
    },
  });

const response = await bundlesocial.socialAccount.socialAccountConnect({
  requestBody: {
    type: 'TIKTOK',
    teamId: team.id,
    redirectUrl: 'https://your-redirect-url.com',
  }
});

// Redirect the user to the response.url
// After the user has connected the account, the user will be redirected to the redirectUrl

const team = await bundlesocial.team.teamGetTeam({
  id: team.id,
});

const socialAccount = team?.socialAccounts?.find((account) => account.type === 'YOUTUBE');
const socialAccountChannelId = socialAccount?.channels?.[0]?.id;

if (socialAccountChannelId) {
  await bundlesocial.socialAccount.socialAccountSetChannel({
    requestBody: {
      type,
      teamId: team.id,
      channelId: socialAccountChannelId,
    }
  });
}

const video = await fs.readFile('./video.mp4');
const videoUpload = await bundlesocial.upload.uploadCreate({
  formData: {
    teamId: team.id,
    file: new Blob([video], { type: 'video/mp4' }),
  }
});

const jpgImage = await fs.readFile('./image.jpg');
const jpgUpload = await bundlesocial.upload.uploadCreate({
  formData: {
    teamId: team.id,
    file: new Blob([jpgImage], { type: 'image/jpeg' }),
  }
});

// Make sure you have uploaded the file before creating a post.
// Make sure you have connected a social account to the team.
const createdPost = await bundlesocial.post.postCreate({
  requestBody: {
    teamId: team.id,
    data: {
      INSTAGRAM: {
        text: 'Test Post',
        type: 'REEL',
        uploadIds: [
          videoUpload?.id
        ]
      },
      YOUTUBE: {
        text: 'Test Post',
        type: 'SHORT',
        madeForKids: false,
        uploadIds: [
          videoUpload?.id
        ],
        privacyStatus: 'PUBLIC',
      },
      TIKTOK: {
        text: 'Test Post',
        uploadIds: [
          videoUpload?.id
        ],
        privacy: 'PUBLIC_TO_EVERYONE',
      },
      REDDIT: {
        sr: 'r/bundlesocial',
        text: 'Test Post',
        uploadIds: [
          jpgUpload.id
        ],
      },
    },
    postDate: new Date().toISOString(),
    socialAccountTypes: ['INSTAGRAM', 'YOUTUBE', 'TIKTOK', 'REDDIT'],
    status: 'SCHEDULED',
    title: 'Test Post',
  }
});

const post = await bundlesocial.post.postGet({
  id: createdPost.id,
});

try {
  const organization = await bundlesocial.organization.organizationGetOrganization();
} catch (error) {
  if (error instanceof ApiError) {
    // Handle the error
    console.log(error?.status, error?.statusText, error?.body);
  } else {
    throw error;
  }
}

// this is a simple example using express
app.post('/webhook', express.json({ type: 'application/json' }), (req, res) => {
  const bundlesocial = new Bundlesocial(apiKey);
  const signature = req.headers['x-signature'];

  let event: WebhookEvent;

  try {
    // Verify the webhook signature and return a typed event
    event = bundlesocial.webhooks.constructEvent(
      req.body,
      signature as string,
      secret,
    );
    // Do something with the event
  } catch (err) {
    console.log(`Webhook signature verification failed.`, err);
    return res.sendStatus(400);
  }

  return res.send();
});