entpb_application_assignment_history_service.go

// Code generated by protoc-gen-entgrpc. DO NOT EDIT.
package entpb

import (
	context "context"
	base64 "encoding/base64"
	entproto "entgo.io/contrib/entproto"
	runtime "entgo.io/contrib/entproto/runtime"
	sqlgraph "entgo.io/ent/dialect/sql/sqlgraph"
	fmt "fmt"
	ent "github.com/Xanonymous-GitHub/carnival/db/pkg/ent"
	application "github.com/Xanonymous-GitHub/carnival/db/pkg/ent/application"
	applicationassignmenthistory "github.com/Xanonymous-GitHub/carnival/db/pkg/ent/applicationassignmenthistory"
	uuid "github.com/google/uuid"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	emptypb "google.golang.org/protobuf/types/known/emptypb"
	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
	strconv "strconv"
)

// ApplicationAssignmentHistoryService implements ApplicationAssignmentHistoryServiceServer
type ApplicationAssignmentHistoryService struct {
	client *ent.Client
	UnimplementedApplicationAssignmentHistoryServiceServer
}

// NewApplicationAssignmentHistoryService returns a new ApplicationAssignmentHistoryService
func NewApplicationAssignmentHistoryService(client *ent.Client) *ApplicationAssignmentHistoryService {
	return &ApplicationAssignmentHistoryService{
		client: client,
	}
}

// toProtoApplicationAssignmentHistory transforms the ent type to the pb type
func toProtoApplicationAssignmentHistory(e *ent.ApplicationAssignmentHistory) (*ApplicationAssignmentHistory, error) {
	v := &ApplicationAssignmentHistory{}
	applicationid, err := e.ApplicationID.MarshalBinary()
	if err != nil {
		return nil, err
	}
	v.ApplicationId = applicationid
	assignee := e.Assignee
	v.Assignee = assignee
	assigner := e.Assigner
	v.Assigner = assigner
	createdtime := timestamppb.New(e.CreatedTime)
	v.CreatedTime = createdtime
	id := int32(e.ID)
	v.Id = id
	if edg := e.Edges.Applications; edg != nil {
		id, err := edg.ID.MarshalBinary()
		if err != nil {
			return nil, err
		}
		v.Applications = &Application{
			Id: id,
		}
	}
	return v, nil
}

// Create implements ApplicationAssignmentHistoryServiceServer.Create
func (svc *ApplicationAssignmentHistoryService) Create(ctx context.Context, req *CreateApplicationAssignmentHistoryRequest) (*ApplicationAssignmentHistory, error) {
	applicationassignmenthistory := req.GetApplicationAssignmentHistory()
	m := svc.client.ApplicationAssignmentHistory.Create()
	var applicationassignmenthistoryApplicationID uuid.UUID
	if err := (&applicationassignmenthistoryApplicationID).UnmarshalBinary(applicationassignmenthistory.GetApplicationId()); err != nil {
		return nil, status.Errorf(codes.InvalidArgument, "invalid argument: %s", err)
	}
	m.SetApplicationID(applicationassignmenthistoryApplicationID)
	applicationassignmenthistoryAssignee := applicationassignmenthistory.GetAssignee()
	m.SetAssignee(applicationassignmenthistoryAssignee)
	applicationassignmenthistoryAssigner := applicationassignmenthistory.GetAssigner()
	m.SetAssigner(applicationassignmenthistoryAssigner)
	applicationassignmenthistoryCreatedTime := runtime.ExtractTime(applicationassignmenthistory.GetCreatedTime())
	m.SetCreatedTime(applicationassignmenthistoryCreatedTime)
	var applicationassignmenthistoryApplications uuid.UUID
	if err := (&applicationassignmenthistoryApplications).UnmarshalBinary(applicationassignmenthistory.GetApplications().GetId()); err != nil {
		return nil, status.Errorf(codes.InvalidArgument, "invalid argument: %s", err)
	}
	m.SetApplicationsID(applicationassignmenthistoryApplications)
	res, err := m.Save(ctx)
	switch {
	case err == nil:
		proto, err := toProtoApplicationAssignmentHistory(res)
		if err != nil {
			return nil, status.Errorf(codes.Internal, "internal error: %s", err)
		}
		return proto, nil
	case sqlgraph.IsUniqueConstraintError(err):
		return nil, status.Errorf(codes.AlreadyExists, "already exists: %s", err)
	case ent.IsConstraintError(err):
		return nil, status.Errorf(codes.InvalidArgument, "invalid argument: %s", err)
	default:
		return nil, status.Errorf(codes.Internal, "internal error: %s", err)
	}

}

// Get implements ApplicationAssignmentHistoryServiceServer.Get
func (svc *ApplicationAssignmentHistoryService) Get(ctx context.Context, req *GetApplicationAssignmentHistoryRequest) (*ApplicationAssignmentHistory, error) {
	var (
		err error
		get *ent.ApplicationAssignmentHistory
	)
	id := int(req.GetId())
	switch req.GetView() {
	case GetApplicationAssignmentHistoryRequest_VIEW_UNSPECIFIED, GetApplicationAssignmentHistoryRequest_BASIC:
		get, err = svc.client.ApplicationAssignmentHistory.Get(ctx, id)
	case GetApplicationAssignmentHistoryRequest_WITH_EDGE_IDS:
		get, err = svc.client.ApplicationAssignmentHistory.Query().
			Where(applicationassignmenthistory.ID(id)).
			WithApplications(func(query *ent.ApplicationQuery) {
				query.Select(application.FieldID)
			}).
			Only(ctx)
	default:
		return nil, status.Error(codes.InvalidArgument, "invalid argument: unknown view")
	}
	switch {
	case err == nil:
		return toProtoApplicationAssignmentHistory(get)
	case ent.IsNotFound(err):
		return nil, status.Errorf(codes.NotFound, "not found: %s", err)
	default:
		return nil, status.Errorf(codes.Internal, "internal error: %s", err)
	}
	return nil, nil

}

// Update implements ApplicationAssignmentHistoryServiceServer.Update
func (svc *ApplicationAssignmentHistoryService) Update(ctx context.Context, req *UpdateApplicationAssignmentHistoryRequest) (*ApplicationAssignmentHistory, error) {
	applicationassignmenthistory := req.GetApplicationAssignmentHistory()
	applicationassignmenthistoryID := int(applicationassignmenthistory.GetId())
	m := svc.client.ApplicationAssignmentHistory.UpdateOneID(applicationassignmenthistoryID)
	var applicationassignmenthistoryApplicationID uuid.UUID
	if err := (&applicationassignmenthistoryApplicationID).UnmarshalBinary(applicationassignmenthistory.GetApplicationId()); err != nil {
		return nil, status.Errorf(codes.InvalidArgument, "invalid argument: %s", err)
	}
	m.SetApplicationID(applicationassignmenthistoryApplicationID)
	applicationassignmenthistoryAssignee := applicationassignmenthistory.GetAssignee()
	m.SetAssignee(applicationassignmenthistoryAssignee)
	applicationassignmenthistoryAssigner := applicationassignmenthistory.GetAssigner()
	m.SetAssigner(applicationassignmenthistoryAssigner)
	var applicationassignmenthistoryApplications uuid.UUID
	if err := (&applicationassignmenthistoryApplications).UnmarshalBinary(applicationassignmenthistory.GetApplications().GetId()); err != nil {
		return nil, status.Errorf(codes.InvalidArgument, "invalid argument: %s", err)
	}
	m.SetApplicationsID(applicationassignmenthistoryApplications)
	res, err := m.Save(ctx)
	switch {
	case err == nil:
		proto, err := toProtoApplicationAssignmentHistory(res)
		if err != nil {
			return nil, status.Errorf(codes.Internal, "internal error: %s", err)
		}
		return proto, nil
	case sqlgraph.IsUniqueConstraintError(err):
		return nil, status.Errorf(codes.AlreadyExists, "already exists: %s", err)
	case ent.IsConstraintError(err):
		return nil, status.Errorf(codes.InvalidArgument, "invalid argument: %s", err)
	default:
		return nil, status.Errorf(codes.Internal, "internal error: %s", err)
	}

}

// Delete implements ApplicationAssignmentHistoryServiceServer.Delete
func (svc *ApplicationAssignmentHistoryService) Delete(ctx context.Context, req *DeleteApplicationAssignmentHistoryRequest) (*emptypb.Empty, error) {
	var err error
	id := int(req.GetId())
	err = svc.client.ApplicationAssignmentHistory.DeleteOneID(id).Exec(ctx)
	switch {
	case err == nil:
		return &emptypb.Empty{}, nil
	case ent.IsNotFound(err):
		return nil, status.Errorf(codes.NotFound, "not found: %s", err)
	default:
		return nil, status.Errorf(codes.Internal, "internal error: %s", err)
	}

}

// List implements ApplicationAssignmentHistoryServiceServer.List
func (svc *ApplicationAssignmentHistoryService) List(ctx context.Context, req *ListApplicationAssignmentHistoryRequest) (*ListApplicationAssignmentHistoryResponse, error) {
	var (
		err      error
		entList  []*ent.ApplicationAssignmentHistory
		pageSize int
	)
	pageSize = int(req.GetPageSize())
	switch {
	case pageSize < 0:
		return nil, status.Errorf(codes.InvalidArgument, "page size cannot be less than zero")
	case pageSize == 0 || pageSize > entproto.MaxPageSize:
		pageSize = entproto.MaxPageSize
	}
	listQuery := svc.client.ApplicationAssignmentHistory.Query().
		Order(ent.Desc(applicationassignmenthistory.FieldID)).
		Limit(pageSize + 1)
	if req.GetPageToken() != "" {
		bytes, err := base64.StdEncoding.DecodeString(req.PageToken)
		if err != nil {
			return nil, status.Errorf(codes.InvalidArgument, "page token is invalid")
		}
		token, err := strconv.ParseInt(string(bytes), 10, 32)
		if err != nil {
			return nil, status.Errorf(codes.InvalidArgument, "page token is invalid")
		}
		pageToken := int(token)
		listQuery = listQuery.
			Where(applicationassignmenthistory.IDLTE(pageToken))
	}
	switch req.GetView() {
	case ListApplicationAssignmentHistoryRequest_VIEW_UNSPECIFIED, ListApplicationAssignmentHistoryRequest_BASIC:
		entList, err = listQuery.All(ctx)
	case ListApplicationAssignmentHistoryRequest_WITH_EDGE_IDS:
		entList, err = listQuery.
			WithApplications(func(query *ent.ApplicationQuery) {
				query.Select(application.FieldID)
			}).
			All(ctx)
	}
	switch {
	case err == nil:
		var nextPageToken string
		if len(entList) == pageSize+1 {
			nextPageToken = base64.StdEncoding.EncodeToString(
				[]byte(fmt.Sprintf("%v", entList[len(entList)-1].ID)))
			entList = entList[:len(entList)-1]
		}
		var pbList []*ApplicationAssignmentHistory
		for _, entEntity := range entList {
			pbEntity, err := toProtoApplicationAssignmentHistory(entEntity)
			if err != nil {
				return nil, status.Errorf(codes.Internal, "internal error: %s", err)
			}
			pbList = append(pbList, pbEntity)
		}
		return &ListApplicationAssignmentHistoryResponse{
			ApplicationAssignmentHistoryList: pbList,
			NextPageToken:                    nextPageToken,
		}, nil
	default:
		return nil, status.Errorf(codes.Internal, "internal error: %s", err)
	}

}