# -*- coding: utf-8 -*-
# Generated by https://github.com/verloop/twirpy/protoc-gen-twirpy.  DO NOT EDIT!
# source: catalog/catalog.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 CatalogServiceServer(TwirpServer):

	def __init__(self, *args, service):
		super().__init__(service=service)
		self._prefix = "/twirp/catalog.CatalogService"
		self._endpoints = {
			"CreateDataset": Endpoint(
				service_name="CatalogService",
				name="CreateDataset",
				function=getattr(service, "CreateDataset"),
				input=_sym_db.GetSymbol("catalog.CreateDatasetRequest"),
				output=_sym_db.GetSymbol("catalog.CreateDatasetResponse"),
			),
			"ListDatasets": Endpoint(
				service_name="CatalogService",
				name="ListDatasets",
				function=getattr(service, "ListDatasets"),
				input=_sym_db.GetSymbol("catalog.ListDatasetsRequest"),
				output=_sym_db.GetSymbol("catalog.ListDatasetsResponse"),
			),
			"ListOrganizationDatasets": Endpoint(
				service_name="CatalogService",
				name="ListOrganizationDatasets",
				function=getattr(service, "ListOrganizationDatasets"),
				input=_sym_db.GetSymbol("catalog.ListOrganizationDatasetsRequest"),
				output=_sym_db.GetSymbol("catalog.ListOrganizationDatasetsResponse"),
			),
			"ListGroupDatasets": Endpoint(
				service_name="CatalogService",
				name="ListGroupDatasets",
				function=getattr(service, "ListGroupDatasets"),
				input=_sym_db.GetSymbol("catalog.ListGroupDatasetsRequest"),
				output=_sym_db.GetSymbol("catalog.ListGroupDatasetsResponse"),
			),
			"GetDataset": Endpoint(
				service_name="CatalogService",
				name="GetDataset",
				function=getattr(service, "GetDataset"),
				input=_sym_db.GetSymbol("catalog.GetDatasetRequest"),
				output=_sym_db.GetSymbol("catalog.GetDatasetResponse"),
			),
			"DeleteDataset": Endpoint(
				service_name="CatalogService",
				name="DeleteDataset",
				function=getattr(service, "DeleteDataset"),
				input=_sym_db.GetSymbol("catalog.DeleteDatasetRequest"),
				output=_sym_db.GetSymbol("catalog.DeleteDatasetResponse"),
			),
			"UpdateDataset": Endpoint(
				service_name="CatalogService",
				name="UpdateDataset",
				function=getattr(service, "UpdateDataset"),
				input=_sym_db.GetSymbol("catalog.UpdateDatasetRequest"),
				output=_sym_db.GetSymbol("catalog.UpdateDatasetResponse"),
			),
			"UpdateProperties": Endpoint(
				service_name="CatalogService",
				name="UpdateProperties",
				function=getattr(service, "UpdateProperties"),
				input=_sym_db.GetSymbol("catalog.UpdatePropertiesRequest"),
				output=_sym_db.GetSymbol("catalog.UpdatePropertiesResponse"),
			),
			"TagRevision": Endpoint(
				service_name="CatalogService",
				name="TagRevision",
				function=getattr(service, "TagRevision"),
				input=_sym_db.GetSymbol("catalog.TagRevisionRequest"),
				output=_sym_db.GetSymbol("catalog.TagRevisionResponse"),
			),
			"UntagRevision": Endpoint(
				service_name="CatalogService",
				name="UntagRevision",
				function=getattr(service, "UntagRevision"),
				input=_sym_db.GetSymbol("catalog.UntagRevisionRequest"),
				output=_sym_db.GetSymbol("catalog.UntagRevisionResponse"),
			),
			"ListTags": Endpoint(
				service_name="CatalogService",
				name="ListTags",
				function=getattr(service, "ListTags"),
				input=_sym_db.GetSymbol("catalog.ListTagsRequest"),
				output=_sym_db.GetSymbol("catalog.ListTagsResponse"),
			),
			"PruneVersion": Endpoint(
				service_name="CatalogService",
				name="PruneVersion",
				function=getattr(service, "PruneVersion"),
				input=_sym_db.GetSymbol("catalog.PruneVersionRequest"),
				output=_sym_db.GetSymbol("catalog.PruneVersionResponse"),
			),
			"PruneRevision": Endpoint(
				service_name="CatalogService",
				name="PruneRevision",
				function=getattr(service, "PruneRevision"),
				input=_sym_db.GetSymbol("catalog.PruneRevisionRequest"),
				output=_sym_db.GetSymbol("catalog.PruneRevisionResponse"),
			),
			"CreateFieldTemplate": Endpoint(
				service_name="CatalogService",
				name="CreateFieldTemplate",
				function=getattr(service, "CreateFieldTemplate"),
				input=_sym_db.GetSymbol("catalog.CreateFieldTemplateRequest"),
				output=_sym_db.GetSymbol("catalog.CreateFieldTemplateResponse"),
			),
			"GetFieldTemplate": Endpoint(
				service_name="CatalogService",
				name="GetFieldTemplate",
				function=getattr(service, "GetFieldTemplate"),
				input=_sym_db.GetSymbol("catalog.GetFieldTemplateRequest"),
				output=_sym_db.GetSymbol("catalog.GetFieldTemplateResponse"),
			),
			"ListFieldTemplates": Endpoint(
				service_name="CatalogService",
				name="ListFieldTemplates",
				function=getattr(service, "ListFieldTemplates"),
				input=_sym_db.GetSymbol("catalog.ListFieldTemplatesRequest"),
				output=_sym_db.GetSymbol("catalog.ListFieldTemplatesResponse"),
			),
			"UpdateFieldTemplate": Endpoint(
				service_name="CatalogService",
				name="UpdateFieldTemplate",
				function=getattr(service, "UpdateFieldTemplate"),
				input=_sym_db.GetSymbol("catalog.UpdateFieldTemplateRequest"),
				output=_sym_db.GetSymbol("catalog.UpdateFieldTemplateResponse"),
			),
			"DeleteFieldTemplate": Endpoint(
				service_name="CatalogService",
				name="DeleteFieldTemplate",
				function=getattr(service, "DeleteFieldTemplate"),
				input=_sym_db.GetSymbol("catalog.DeleteFieldTemplateRequest"),
				output=_sym_db.GetSymbol("catalog.DeleteFieldTemplateResponse"),
			),
			"AttachFieldTemplate": Endpoint(
				service_name="CatalogService",
				name="AttachFieldTemplate",
				function=getattr(service, "AttachFieldTemplate"),
				input=_sym_db.GetSymbol("catalog.AttachFieldTemplateRequest"),
				output=_sym_db.GetSymbol("catalog.AttachFieldTemplateResponse"),
			),
			"DetachFieldTemplate": Endpoint(
				service_name="CatalogService",
				name="DetachFieldTemplate",
				function=getattr(service, "DetachFieldTemplate"),
				input=_sym_db.GetSymbol("catalog.DetachFieldTemplateRequest"),
				output=_sym_db.GetSymbol("catalog.DetachFieldTemplateResponse"),
			),
			"GetDatasetTemplate": Endpoint(
				service_name="CatalogService",
				name="GetDatasetTemplate",
				function=getattr(service, "GetDatasetTemplate"),
				input=_sym_db.GetSymbol("catalog.GetDatasetTemplateRequest"),
				output=_sym_db.GetSymbol("catalog.GetDatasetTemplateResponse"),
			),
			"ListRecommendedFields": Endpoint(
				service_name="CatalogService",
				name="ListRecommendedFields",
				function=getattr(service, "ListRecommendedFields"),
				input=_sym_db.GetSymbol("catalog.ListRecommendedFieldsRequest"),
				output=_sym_db.GetSymbol("catalog.ListRecommendedFieldsResponse"),
			),
		}

class CatalogServiceClient(TwirpClient):

	def CreateDataset(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/CreateDataset",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.CreateDatasetResponse"),
			**kwargs,
		)

	def ListDatasets(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/ListDatasets",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.ListDatasetsResponse"),
			**kwargs,
		)

	def ListOrganizationDatasets(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/ListOrganizationDatasets",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.ListOrganizationDatasetsResponse"),
			**kwargs,
		)

	def ListGroupDatasets(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/ListGroupDatasets",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.ListGroupDatasetsResponse"),
			**kwargs,
		)

	def GetDataset(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/GetDataset",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.GetDatasetResponse"),
			**kwargs,
		)

	def DeleteDataset(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/DeleteDataset",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.DeleteDatasetResponse"),
			**kwargs,
		)

	def UpdateDataset(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/UpdateDataset",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.UpdateDatasetResponse"),
			**kwargs,
		)

	def UpdateProperties(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/UpdateProperties",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.UpdatePropertiesResponse"),
			**kwargs,
		)

	def TagRevision(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/TagRevision",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.TagRevisionResponse"),
			**kwargs,
		)

	def UntagRevision(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/UntagRevision",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.UntagRevisionResponse"),
			**kwargs,
		)

	def ListTags(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/ListTags",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.ListTagsResponse"),
			**kwargs,
		)

	def PruneVersion(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/PruneVersion",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.PruneVersionResponse"),
			**kwargs,
		)

	def PruneRevision(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/PruneRevision",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.PruneRevisionResponse"),
			**kwargs,
		)

	def CreateFieldTemplate(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/CreateFieldTemplate",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.CreateFieldTemplateResponse"),
			**kwargs,
		)

	def GetFieldTemplate(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/GetFieldTemplate",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.GetFieldTemplateResponse"),
			**kwargs,
		)

	def ListFieldTemplates(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/ListFieldTemplates",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.ListFieldTemplatesResponse"),
			**kwargs,
		)

	def UpdateFieldTemplate(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/UpdateFieldTemplate",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.UpdateFieldTemplateResponse"),
			**kwargs,
		)

	def DeleteFieldTemplate(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/DeleteFieldTemplate",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.DeleteFieldTemplateResponse"),
			**kwargs,
		)

	def AttachFieldTemplate(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/AttachFieldTemplate",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.AttachFieldTemplateResponse"),
			**kwargs,
		)

	def DetachFieldTemplate(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/DetachFieldTemplate",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.DetachFieldTemplateResponse"),
			**kwargs,
		)

	def GetDatasetTemplate(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/GetDatasetTemplate",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.GetDatasetTemplateResponse"),
			**kwargs,
		)

	def ListRecommendedFields(self, *args, ctx, request, **kwargs):
		return self._make_request(
			url="/twirp/catalog.CatalogService/ListRecommendedFields",
			ctx=ctx,
			request=request,
			response_obj=_sym_db.GetSymbol("catalog.ListRecommendedFieldsResponse"),
			**kwargs,
		)