KaneAI - World’s First E2E Software Testing Agent.Book a Demo Join TestMu Conference

How to use oauthOctokit method in argos

Best JavaScript code snippet using argos

synchronizer.js

Source:synchronizer.js

1/* eslint-disable no-await-in-loop */2import {3  getOAuthOctokit,4  getTokenOctokit,5  getInstallationOctokit,6} from "@argos-ci/github";7import {8  Installation,9  Organization,10  Repository,11  User,12  UserOrganizationRight,13  UserRepositoryRight,14  UserInstallationRight,15  InstallationRepositoryRight,16} from "@argos-ci/database/models";17import config from "@argos-ci/config";18export async function getOrCreateInstallation(payload) {19  const installation = await Installation.query()20    .where({ githubId: payload.githubId })21    .first();22  if (installation) return installation;23  return Installation.query().insertAndFetch(payload);24}25async function checkAccessTokenValidity(accessToken) {26  const oauthOctokit = getOAuthOctokit();27  try {28    await oauthOctokit.apps.checkToken({29      access_token: accessToken,30      client_id: config.get("github.clientId"),31    });32  } catch (error) {33    if (error.status === 404) {34      return false;35    }36    throw error;37  }38  return true;39}40const OWNER_ORGANIZATION = "Organization";41const OWNER_USER = "User";42export class GitHubSynchronizer {43  constructor(synchronization) {44    this.synchronization = synchronization;45    this.repositories = [];46    this.organizationIds = [];47  }48  async synchronizeAppRepositories(installationId) {49    const options =50      this.octokit.apps.listReposAccessibleToInstallation.endpoint.DEFAULTS;51    const githubRepositories = await this.octokit.paginate(options);52    const { repositories, organizations } = await this.synchronizeRepositories(53      githubRepositories54    );55    await this.synchronizeInstallationRepositoryRights(56      repositories,57      installationId58    );59    return { repositories, organizations };60  }61  async getInstallationRepositories(options) {62    try {63      return await this.octokit.paginate(options);64    } catch (error) {65      if (error.response.status === 404) return [];66      throw error;67    }68  }69  async synchronizeUserInstallationRepositories(installation) {70    const options =71      this.octokit.apps.listInstallationReposForAuthenticatedUser.endpoint.merge(72        { installation_id: installation.githubId }73      );74    const githubRepositories = await this.getInstallationRepositories(options);75    const { repositories, organizations } = await this.synchronizeRepositories(76      githubRepositories77    );78    await this.synchronizeInstallationRepositoryRights(79      repositories,80      installation.id81    );82    return { repositories, organizations };83  }84  async synchronizeRepositories(githubRepositories) {85    const [86      {87        owners: organizations,88        ownerIdByRepositoryId: organizationIdByRepositoryId,89      },90      { ownerIdByRepositoryId: userIdByRepositoryId },91    ] = await Promise.all([92      this.synchronizeOwners(githubRepositories, OWNER_ORGANIZATION),93      this.synchronizeOwners(githubRepositories, OWNER_USER),94    ]);95    const repositories = await Promise.all(96      githubRepositories.map(async (githubRepository) => {97        const data = {98          githubId: githubRepository.id,99          name: githubRepository.name,100          organizationId:101            organizationIdByRepositoryId[githubRepository.id] || null,102          userId: userIdByRepositoryId[githubRepository.id] || null,103          private: githubRepository.private,104          defaultBranch: githubRepository.default_branch,105        };106        let [repository] = await Repository.query().where({107          githubId: githubRepository.id,108        });109        if (repository) {110          return repository.$query().patchAndFetch(data);111        }112        return Repository.query().insertAndFetch({ ...data, enabled: false });113      })114    );115    return { repositories, organizations };116  }117  async synchronizeOwners(githubRepositories, type) {118    const githubOwners = githubRepositories.reduce(119      (githubOwners, githubRepository) => {120        if (githubRepository.owner.type !== type) {121          return githubOwners;122        }123        let githubOwner = githubOwners.find(124          ({ id }) => id === githubRepository.owner.id125        );126        if (!githubOwner) {127          githubOwner = githubRepository.owner;128          githubOwners.push(githubRepository.owner);129        }130        return githubOwners;131      },132      []133    );134    let owners;135    switch (type) {136      case OWNER_ORGANIZATION:137        owners = await Promise.all(138          githubOwners.map((githubOwner) =>139            this.synchronizeOrganization(githubOwner)140          )141        );142        break;143      case OWNER_USER:144        owners = await Promise.all(145          githubOwners.map((githubOwner) => this.synchronizeUser(githubOwner))146        );147        break;148      default:149        throw new Error(`Unsupported type ${type}`);150    }151    return {152      owners,153      ownerIdByRepositoryId: githubRepositories.reduce(154        (ownerIdByRepositoryId, githubRepository) => {155          if (githubRepository.owner.type === type) {156            ownerIdByRepositoryId[githubRepository.id] = owners.find(157              (owner) => owner.githubId === githubRepository.owner.id158            ).id;159          }160          return ownerIdByRepositoryId;161        },162        {}163      ),164    };165  }166  // eslint-disable-next-line class-methods-use-this167  async synchronizeOrganization(githubOrganization) {168    const organizationData = await this.octokit.orgs.get({169      org: githubOrganization.login,170    });171    githubOrganization = organizationData.data;172    let [organization] = await Organization.query().where({173      githubId: githubOrganization.id,174    });175    const data = {176      githubId: githubOrganization.id,177      name: githubOrganization.name,178      login: githubOrganization.login,179    };180    if (organization) {181      await organization.$query().patchAndFetch(data);182    } else {183      organization = await Organization.query().insert(data);184    }185    return organization;186  }187  // eslint-disable-next-line class-methods-use-this188  async synchronizeUser(githubUser) {189    const data = { githubId: githubUser.id, login: githubUser.login };190    let user = await User.query().where({ githubId: githubUser.id }).first();191    if (user) {192      await user.$query().patchAndFetch(data);193    } else {194      user = await User.query().insert(data);195    }196    return user;197  }198  async synchronizeInstallationRepositoryRights(repositories, installationId) {199    const installationRepositoryRights =200      await InstallationRepositoryRight.query().where({201        installationId,202      });203    await Promise.all(204      repositories.map(async (repository) => {205        const hasRights = installationRepositoryRights.some(206          ({ repositoryId }) => repositoryId === repository.id207        );208        if (!hasRights) {209          await InstallationRepositoryRight.query().insert({210            installationId,211            repositoryId: repository.id,212          });213        }214      })215    );216    await Promise.all(217      installationRepositoryRights.map(async (installationRepositoryRight) => {218        const repositoryStillExists = repositories.find(219          ({ id }) => id === installationRepositoryRight.repositoryId220        );221        if (!repositoryStillExists) {222          await installationRepositoryRight.$query().delete();223        }224      })225    );226  }227  async synchronizeRepositoryRights(repositories, userId) {228    const userRepositoryRights = await UserRepositoryRight.query().where({229      userId,230    });231    await Promise.all(232      repositories.map(async (repository) => {233        const hasRights = userRepositoryRights.some(234          ({ repositoryId }) => repositoryId === repository.id235        );236        if (!hasRights) {237          await UserRepositoryRight.query().insert({238            userId,239            repositoryId: repository.id,240          });241        }242      })243    );244    await Promise.all(245      userRepositoryRights.map(async (userRepositoryRight) => {246        const repositoryStillExists = repositories.find(247          ({ id }) => id === userRepositoryRight.repositoryId248        );249        if (!repositoryStillExists) {250          await userRepositoryRight.$query().delete();251        }252      })253    );254  }255  async synchronizeOrganizationRights(organizations, userId) {256    const userOrganizationRights = await UserOrganizationRight.query().where({257      userId,258    });259    await Promise.all(260      organizations.map(async (organization) => {261        const hasRights = userOrganizationRights.some(262          ({ organizationId }) => organizationId === organization.id263        );264        if (!hasRights) {265          await UserOrganizationRight.query().insert({266            userId,267            organizationId: organization.id,268          });269        }270      })271    );272    await Promise.all(273      userOrganizationRights.map(async (userOrganizationRight) => {274        const organizationStillExists = organizations.find(275          ({ id }) => id === userOrganizationRight.organizationId276        );277        if (!organizationStillExists) {278          await userOrganizationRight.$query().delete();279        }280      })281    );282  }283  async synchronizeUserInstallations() {284    const options =285      this.octokit.apps.listInstallationsForAuthenticatedUser.endpoint.DEFAULTS;286    const githubInstallations = await this.octokit.paginate(options);287    return Promise.all(288      githubInstallations.map(async (githubInstallation) => {289        return getOrCreateInstallation({290          githubId: githubInstallation.id,291          deleted: false,292        });293      })294    );295  }296  async synchronizeUserInstallationRights(installations, userId) {297    const userInstallationRights = await UserInstallationRight.query().where({298      userId,299    });300    await Promise.all(301      installations.map(async (installation) => {302        const exists = userInstallationRights.some(303          ({ installationId }) => installationId === installation.id304        );305        if (!exists) {306          await UserInstallationRight.query().insertAndFetch({307            userId,308            installationId: installation.id,309          });310        }311      })312    );313    await Promise.all(314      userInstallationRights.map(async (userInstallationRight) => {315        const installationStillExists = installations.find(316          ({ id }) => id === userInstallationRight.installationId317        );318        if (!installationStillExists) {319          await userInstallationRight.$query().delete();320        }321      })322    );323    return installations;324  }325  async synchronize() {326    this.synchronization = await this.synchronization.$query();327    switch (this.synchronization.type) {328      case "installation":329        return this.synchronizeFromInstallation(330          this.synchronization.installationId331        );332      case "user":333        return this.synchronizeFromUser(this.synchronization.userId);334      default:335        throw new Error(336          `Unknown synchronization type "${this.synchronization.type}"`337        );338    }339  }340  async synchronizeFromInstallation(installationId) {341    const installation = await Installation.query()342      .findById(installationId)343      .withGraphFetched("users");344    if (installation.deleted) {345      await Promise.all(346        installation.users.map(async (user) =>347          this.synchronizeFromUser(user.id)348        )349      );350      await this.synchronizeInstallationRepositoryRights([], installationId);351      return;352    }353    const octokit = await getInstallationOctokit(installation.githubId);354    // If we don't get an octokit, then the installation has been removed355    // we deleted the installation356    if (!octokit) {357      await installation.$query().patch({ deleted: true });358      return;359    }360    this.octokit = octokit;361    await this.synchronizeAppRepositories(installationId);362    await Promise.all(363      installation.users.map(async (user) => this.synchronizeFromUser(user.id))364    );365  }366  async synchronizeFromUser(userId) {367    const user = await User.query().findById(userId);368    const tokenValid = await checkAccessTokenValidity(user.accessToken);369    if (!tokenValid) {370      await this.synchronizeUserInstallationRights([], userId);371      await Promise.all([372        this.synchronizeRepositoryRights([], userId),373        this.synchronizeOrganizationRights([], userId),374      ]);375      return;376    }377    this.octokit = getTokenOctokit(user.accessToken);378    const installations = await this.synchronizeUserInstallations(userId);379    await this.synchronizeUserInstallationRights(installations, userId);380    const results = await Promise.all(381      installations.map((installation) =>382        this.synchronizeUserInstallationRepositories(installation)383      )384    );385    const { repositories, organizations } = results.reduce(386      (all, result) => {387        all.repositories = [...all.repositories, ...result.repositories];388        all.organizations = [...all.organizations, ...result.organizations];389        return all;390      },391      { repositories: [], organizations: [] }392    );393    await Promise.all([394      this.synchronizeRepositoryRights(repositories, userId),395      this.synchronizeOrganizationRights(organizations, userId),396    ]);397  }...

Using AI Code Generation

1const { oauthOctokit } = require('argosy-service-github')2const github = oauthOctokit('access_token')3github.issues.create({4})5const { github } = require('argosy-service-github')6const github = github('username', 'password')7github.issues.create({8})

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.