# -*- coding: utf-8 -*-
# Generated by https://github.com/verloop/twirpy/protoc-gen-twirpy.  DO NOT EDIT!
# source: references.proto

from google.protobuf import symbol_database as _symbol_database

from twirp.base import Endpoint
from twirp.server import TwirpServer
from twirp.client import TwirpClient

_sym_db = _symbol_database.Default()

class ReferencesServiceServer(TwirpServer):

	def __init__(self, *args, service):
		super().__init__(service=service)
		self._prefix = "/twirp/references.ReferencesService"
		self._endpoints = {
			"GetReference": Endpoint(
				service_name="ReferencesService",
				name="GetReference",
				function=getattr(service, "GetReference"),
				input=_sym_db.GetSymbol("references.GetReferenceRequest"),
				output=_sym_db.GetSymbol("references.GetReferenceResponse"),
			),
			"ListReferences": Endpoint(
				service_name="ReferencesService",
				name="ListReferences",
				function=getattr(service, "ListReferences"),
				input=_sym_db.GetSymbol("references.ListReferencesRequest"),
				output=_sym_db.GetSymbol("references.ListReferencesResponse"),
			),
			"CreateReference": Endpoint(
				service_name="ReferencesService",
				name="CreateReference",
				function=getattr(service, "CreateReference"),
				input=_sym_db.GetSymbol("references.CreateReferenceRequest"),
				output=_sym_db.GetSymbol("references.CreateReferenceResponse"),
			),
			"IngestReference": Endpoint(
				service_name="ReferencesService",
				name="IngestReference",
				function=getattr(service, "IngestReference"),
				input=_sym_db.GetSymbol("references.IngestReferenceRequest"),
				output=_sym_db.GetSymbol("references.IngestReferenceResponse"),
			),
			"UpdateReference": Endpoint(
				service_name="ReferencesService",
				name="UpdateReference",
				function=getattr(service, "UpdateReference"),
				input=_sym_db.GetSymbol("references.UpdateReferenceRequest"),
				output=_sym_db.GetSymbol("references.UpdateReferenceResponse"),
			),
			"DeleteReference": Endpoint(
				service_name="ReferencesService",
				name="DeleteReference",
				function=getattr(service, "DeleteReference"),
				input=_sym_db.GetSymbol("references.DeleteReferenceRequest"),
				output=_sym_db.GetSymbol("references.DeleteReferenceResponse"),
			),
			"ForceCurrentJobFail": Endpoint(
				service_name="ReferencesService",
				name="ForceCurrentJobFail",
				function=getattr(service, "ForceCurrentJobFail"),
				input=_sym_db.GetSymbol("references.ForceCurrentJobFailRequest"),
				output=_sym_db.GetSymbol("references.ForceCurrentJobFailResponse"),
			),
			"Healthz": Endpoint(
				service_name="ReferencesService",
				name="Healthz",
				function=getattr(service, "Healthz"),
				input=_sym_db.GetSymbol("references.HealthzRequest"),
				output=_sym_db.GetSymbol("references.HealthzResponse"),
			),
			"ListJobs": Endpoint(
				service_name="ReferencesService",
				name="ListJobs",
				function=getattr(service, "ListJobs"),
				input=_sym_db.GetSymbol("references.ListJobsRequest"),
				output=_sym_db.GetSymbol("references.ListJobsResponse"),
			),
			"GetJob": Endpoint(
				service_name="ReferencesService",
				name="GetJob",
				function=getattr(service, "GetJob"),
				input=_sym_db.GetSymbol("references.GetJobRequest"),
				output=_sym_db.GetSymbol("references.GetJobResponse"),
			),
		}

class ReferencesServiceClient(TwirpClient):

	def GetReference(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/references.ReferencesService/GetReference",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("references.GetReferenceResponse"),
			**kwargs,
		)

	def ListReferences(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/references.ReferencesService/ListReferences",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("references.ListReferencesResponse"),
			**kwargs,
		)

	def CreateReference(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/references.ReferencesService/CreateReference",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("references.CreateReferenceResponse"),
			**kwargs,
		)

	def IngestReference(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/references.ReferencesService/IngestReference",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("references.IngestReferenceResponse"),
			**kwargs,
		)

	def UpdateReference(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/references.ReferencesService/UpdateReference",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("references.UpdateReferenceResponse"),
			**kwargs,
		)

	def DeleteReference(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/references.ReferencesService/DeleteReference",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("references.DeleteReferenceResponse"),
			**kwargs,
		)

	def ForceCurrentJobFail(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/references.ReferencesService/ForceCurrentJobFail",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("references.ForceCurrentJobFailResponse"),
			**kwargs,
		)

	def Healthz(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/references.ReferencesService/Healthz",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("references.HealthzResponse"),
			**kwargs,
		)

	def ListJobs(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/references.ReferencesService/ListJobs",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("references.ListJobsResponse"),
			**kwargs,
		)

	def GetJob(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/references.ReferencesService/GetJob",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("references.GetJobResponse"),
			**kwargs,
		)