import { Injectable, NotFoundException } from "@nestjs/common";
import { Repository, SelectQueryBuilder } from "typeorm";
import { InjectRepository } from "@nestjs/typeorm";

import { PageDto } from "../common/dtos/page.dto";

import { RepoInfo } from "../repo/dtos/repo-info.dto";
import { PagerService } from "../common/services/pager.service";
import { DbUserRepo } from "./user-repo.entity";
import { UserRepoOptionsDto } from "./dtos/user-repo-options.dto";

@Injectable()
export class UserReposService {
  constructor(
    @InjectRepository(DbUserRepo, "ApiConnection")
    private userRepoRepository: Repository<DbUserRepo>,
    private pagerService: PagerService
  ) {}

  baseQueryBuilder(): SelectQueryBuilder<DbUserRepo> {
    const builder = this.userRepoRepository.createQueryBuilder("user_repos");

    return builder;
  }

  async findOneById(id: number): Promise<DbUserRepo> {
    const queryBuilder = this.baseQueryBuilder();

    queryBuilder.where("id = :id", { id });

    const item: DbUserRepo | null = await queryBuilder.getOne();

    if (!item) {
      throw new NotFoundException();
    }

    return item;
  }

  async addUserRepo(userId: number, repo: RepoInfo) {
    const newUserRepo = this.userRepoRepository.create({
      user_id: userId,
      repo_id: repo.id,
      full_name: repo.fullName,
    });

    return this.userRepoRepository.save(newUserRepo);
  }

  async findAllByUserId(pageOptionsDto: UserRepoOptionsDto, userId: string): Promise<PageDto<DbUserRepo>> {
    const queryBuilder = this.userRepoRepository.createQueryBuilder("user_repos");

    queryBuilder.where("user_repos.user_id = :userId", { userId });

    return this.pagerService.applyPagination<DbUserRepo>({
      queryBuilder,
      pageOptionsDto,
    });
  }
}