#!/usr/bin/env python # # Copyright 2007 Google Inc. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. # """Service configuration for remote API. This module is shared by both the remote_api_stub and the handler. """ import sys from google.appengine.api import api_base_pb from google.appengine.api import mail_service_pb from google.appengine.api import urlfetch_service_pb from google.appengine.api import user_service_pb from google.appengine.api.app_identity import app_identity_service_pb from google.appengine.api.blobstore import blobstore_service_pb from google.appengine.api.capabilities import capability_service_pb from google.appengine.api.channel import channel_service_pb from google.appengine.api.files import file_service_pb from google.appengine.api.images import images_service_pb from google.appengine.api.logservice import log_service_pb from google.appengine.api.memcache import memcache_service_pb from google.appengine.api.modules import modules_service_pb from google.appengine.api.prospective_search import prospective_search_pb from google.appengine.api.remote_socket import remote_socket_service_pb from google.appengine.api.search import search_service_pb from google.appengine.api.system import system_service_pb from google.appengine.api.taskqueue import taskqueue_service_pb from google.appengine.api.xmpp import xmpp_service_pb from google.appengine.datastore import datastore_pb from google.appengine.datastore import datastore_v4_pb from google.appengine.ext.remote_api import remote_api_pb SERVICE_PB_MAP = { 'app_identity_service': { 'SignForApp': (app_identity_service_pb.SignForAppRequest, app_identity_service_pb.SignForAppResponse), 'GetPublicCertificatesForApp': ( app_identity_service_pb.GetPublicCertificateForAppRequest, app_identity_service_pb.GetPublicCertificateForAppResponse), 'GetServiceAccountName': ( app_identity_service_pb.GetServiceAccountNameRequest, app_identity_service_pb.GetServiceAccountNameResponse), 'GetDefaultGcsBucketName': ( app_identity_service_pb.GetDefaultGcsBucketNameRequest, app_identity_service_pb.GetDefaultGcsBucketNameResponse), 'GetAccessToken': (app_identity_service_pb.GetAccessTokenRequest, app_identity_service_pb.GetAccessTokenResponse), }, 'blobstore': { 'CreateUploadURL': (blobstore_service_pb.CreateUploadURLRequest, blobstore_service_pb.CreateUploadURLResponse), 'DeleteBlob': (blobstore_service_pb.DeleteBlobRequest, api_base_pb.VoidProto), 'FetchData': (blobstore_service_pb.FetchDataRequest, blobstore_service_pb.FetchDataResponse), 'DecodeBlobKey': (blobstore_service_pb.DecodeBlobKeyRequest, blobstore_service_pb.DecodeBlobKeyResponse), 'CreateEncodedGoogleStorageKey': ( blobstore_service_pb.CreateEncodedGoogleStorageKeyRequest, blobstore_service_pb.CreateEncodedGoogleStorageKeyResponse), }, 'capability_service': { 'IsEnabled': (capability_service_pb.IsEnabledRequest, capability_service_pb.IsEnabledResponse), }, 'channel': { 'CreateChannel': (channel_service_pb.CreateChannelRequest, channel_service_pb.CreateChannelResponse), 'SendChannelMessage': (channel_service_pb.SendMessageRequest, api_base_pb.VoidProto), }, 'datastore_v3': { 'Get': (datastore_pb.GetRequest, datastore_pb.GetResponse), 'Put': (datastore_pb.PutRequest, datastore_pb.PutResponse), 'Delete': (datastore_pb.DeleteRequest, datastore_pb.DeleteResponse), 'AllocateIds': (datastore_pb.AllocateIdsRequest, datastore_pb.AllocateIdsResponse), 'RunQuery': (datastore_pb.Query, datastore_pb.QueryResult), 'Next': (datastore_pb.NextRequest, datastore_pb.QueryResult), 'BeginTransaction': (datastore_pb.BeginTransactionRequest, datastore_pb.Transaction), 'Commit': (datastore_pb.Transaction, datastore_pb.CommitResponse), 'Rollback': (datastore_pb.Transaction, api_base_pb.VoidProto), 'GetIndices': (datastore_pb.GetIndicesRequest, datastore_pb.CompositeIndices), }, 'datastore_v4': { 'AllocateIds': (datastore_v4_pb.AllocateIdsRequest, datastore_v4_pb.AllocateIdsResponse), }, 'file': { 'Create': (file_service_pb.CreateRequest, file_service_pb.CreateResponse), 'Open': (file_service_pb.OpenRequest, file_service_pb.OpenResponse), 'Close': (file_service_pb.CloseRequest, file_service_pb.CloseResponse), 'Append': (file_service_pb.AppendRequest, file_service_pb.AppendResponse), 'Stat': (file_service_pb.StatRequest, file_service_pb.StatResponse), 'Delete': (file_service_pb.DeleteRequest, file_service_pb.DeleteResponse), 'Read': (file_service_pb.ReadRequest, file_service_pb.ReadResponse), 'ReadKeyValue': (file_service_pb.ReadKeyValueRequest, file_service_pb.ReadKeyValueResponse), 'Shuffle': (file_service_pb.ShuffleRequest, file_service_pb.ShuffleResponse), 'GetShuffleStatus': (file_service_pb.GetShuffleStatusRequest, file_service_pb.GetShuffleStatusResponse), 'GetCapabilities': (file_service_pb.GetCapabilitiesRequest, file_service_pb.GetCapabilitiesResponse), 'GetDefaultGsBucketName': ( file_service_pb.GetDefaultGsBucketNameRequest, file_service_pb.GetDefaultGsBucketNameResponse), 'ListDir': (file_service_pb.ListDirRequest, file_service_pb.ListDirResponse), }, 'images': { 'Transform': (images_service_pb.ImagesTransformRequest, images_service_pb.ImagesTransformResponse), 'Composite': (images_service_pb.ImagesCompositeRequest, images_service_pb.ImagesCompositeResponse), 'Histogram': (images_service_pb.ImagesHistogramRequest, images_service_pb.ImagesHistogramResponse), 'GetUrlBase': (images_service_pb.ImagesGetUrlBaseRequest, images_service_pb.ImagesGetUrlBaseResponse), 'DeleteUrlBase': (images_service_pb.ImagesDeleteUrlBaseRequest, images_service_pb.ImagesDeleteUrlBaseResponse), }, 'logservice': { 'Flush': (log_service_pb.FlushRequest, api_base_pb.VoidProto), 'SetStatus': (log_service_pb.SetStatusRequest, api_base_pb.VoidProto), 'Read': (log_service_pb.LogReadRequest, log_service_pb.LogReadResponse), }, 'mail': { 'Send': (mail_service_pb.MailMessage, api_base_pb.VoidProto), 'SendToAdmins': (mail_service_pb.MailMessage, api_base_pb.VoidProto), }, 'matcher': { 'Subscribe': (prospective_search_pb.SubscribeRequest, prospective_search_pb.SubscribeResponse), 'Unsubscribe': (prospective_search_pb.UnsubscribeRequest, prospective_search_pb.UnsubscribeResponse), 'ListSubscriptions': (prospective_search_pb.ListSubscriptionsRequest, prospective_search_pb.ListSubscriptionsResponse), 'ListTopics': (prospective_search_pb.ListTopicsRequest, prospective_search_pb.ListTopicsResponse), 'Match': (prospective_search_pb.MatchRequest, prospective_search_pb.MatchResponse), }, 'memcache': { 'Get': (memcache_service_pb.MemcacheGetRequest, memcache_service_pb.MemcacheGetResponse), 'Set': (memcache_service_pb.MemcacheSetRequest, memcache_service_pb.MemcacheSetResponse), 'Delete': (memcache_service_pb.MemcacheDeleteRequest, memcache_service_pb.MemcacheDeleteResponse), 'Increment': (memcache_service_pb.MemcacheIncrementRequest, memcache_service_pb.MemcacheIncrementResponse), 'BatchIncrement': (memcache_service_pb.MemcacheBatchIncrementRequest, memcache_service_pb.MemcacheBatchIncrementResponse), 'FlushAll': (memcache_service_pb.MemcacheFlushRequest, memcache_service_pb.MemcacheFlushResponse), 'Stats': (memcache_service_pb.MemcacheStatsRequest, memcache_service_pb.MemcacheStatsResponse), }, 'remote_datastore': { 'RunQuery': (datastore_pb.Query, datastore_pb.QueryResult), 'TransactionQuery': (datastore_pb.Query, remote_api_pb.TransactionQueryResult), 'Transaction': (remote_api_pb.TransactionRequest, datastore_pb.PutResponse), 'GetIDs': (datastore_pb.PutRequest, datastore_pb.PutResponse), 'GetIDsXG': (datastore_pb.PutRequest, datastore_pb.PutResponse), }, 'remote_socket': { 'CreateSocket': (remote_socket_service_pb.CreateSocketRequest, remote_socket_service_pb.CreateSocketReply), 'Bind': (remote_socket_service_pb.BindRequest, remote_socket_service_pb.BindReply), 'GetSocketName': (remote_socket_service_pb.GetSocketNameRequest, remote_socket_service_pb.GetSocketNameReply), 'GetPeerName': (remote_socket_service_pb.GetPeerNameRequest, remote_socket_service_pb.GetPeerNameReply), 'SetSocketOptions': (remote_socket_service_pb.SetSocketOptionsRequest, remote_socket_service_pb.SetSocketOptionsReply), 'GetSocketOptions': (remote_socket_service_pb.GetSocketOptionsRequest, remote_socket_service_pb.GetSocketOptionsReply), 'Connect': (remote_socket_service_pb.ConnectRequest, remote_socket_service_pb.ConnectReply), 'Listen': (remote_socket_service_pb.ListenRequest, remote_socket_service_pb.ListenReply), 'Accept': (remote_socket_service_pb.AcceptRequest, remote_socket_service_pb.AcceptReply), 'ShutDown': (remote_socket_service_pb.ShutDownRequest, remote_socket_service_pb.ShutDownReply), 'Close': (remote_socket_service_pb.CloseRequest, remote_socket_service_pb.CloseReply), 'Send': (remote_socket_service_pb.SendRequest, remote_socket_service_pb.SendReply), 'Receive': (remote_socket_service_pb.ReceiveRequest, remote_socket_service_pb.ReceiveReply), 'Poll': (remote_socket_service_pb.PollRequest, remote_socket_service_pb.PollReply), 'Resolve': (remote_socket_service_pb.ResolveRequest, remote_socket_service_pb.ResolveReply), }, 'search': { 'IndexDocument': (search_service_pb.IndexDocumentRequest, search_service_pb.IndexDocumentResponse), 'DeleteDocument': (search_service_pb.DeleteDocumentRequest, search_service_pb.DeleteDocumentResponse), 'ListDocuments': (search_service_pb.ListDocumentsRequest, search_service_pb.ListDocumentsResponse), 'ListIndexes': (search_service_pb.ListIndexesRequest, search_service_pb.ListIndexesResponse), 'Search': (search_service_pb.SearchRequest, search_service_pb.SearchResponse), 'DeleteSchema': (search_service_pb.DeleteSchemaRequest, search_service_pb.DeleteSchemaResponse), }, 'modules': { 'GetModules': (modules_service_pb.GetModulesRequest, modules_service_pb.GetModulesResponse), 'GetVersions': (modules_service_pb.GetVersionsRequest, modules_service_pb.GetVersionsResponse), 'GetDefaultVersion': (modules_service_pb.GetDefaultVersionRequest, modules_service_pb.GetDefaultVersionResponse), 'GetNumInstances': (modules_service_pb.GetNumInstancesRequest, modules_service_pb.GetNumInstancesResponse), 'SetNumInstances': (modules_service_pb.SetNumInstancesRequest, modules_service_pb.SetNumInstancesResponse), 'StartModule': (modules_service_pb.StartModuleRequest, modules_service_pb.StartModuleResponse), 'StopModule': (modules_service_pb.StopModuleRequest, modules_service_pb.StopModuleResponse), 'GetHostname': (modules_service_pb.GetHostnameRequest, modules_service_pb.GetHostnameResponse), }, 'system': { 'GetSystemStats': (system_service_pb.GetSystemStatsRequest, system_service_pb.GetSystemStatsResponse), 'StartBackgroundRequest': ( system_service_pb.StartBackgroundRequestRequest, system_service_pb.StartBackgroundRequestResponse), }, 'taskqueue': { 'Add': (taskqueue_service_pb.TaskQueueAddRequest, taskqueue_service_pb.TaskQueueAddResponse), 'BulkAdd': (taskqueue_service_pb.TaskQueueBulkAddRequest, taskqueue_service_pb.TaskQueueBulkAddResponse), 'FetchQueues': (taskqueue_service_pb.TaskQueueFetchQueuesRequest, taskqueue_service_pb.TaskQueueFetchQueuesResponse), 'FetchQueueStats': ( taskqueue_service_pb.TaskQueueFetchQueueStatsRequest, taskqueue_service_pb.TaskQueueFetchQueueStatsResponse), 'Delete': (taskqueue_service_pb.TaskQueueDeleteRequest, taskqueue_service_pb.TaskQueueDeleteResponse), 'ForceRun': (taskqueue_service_pb.TaskQueueForceRunRequest, taskqueue_service_pb.TaskQueueForceRunResponse), 'UpdateQueue': (taskqueue_service_pb.TaskQueueUpdateQueueRequest, taskqueue_service_pb.TaskQueueUpdateQueueResponse), 'PauseQueue': (taskqueue_service_pb.TaskQueuePauseQueueRequest, taskqueue_service_pb.TaskQueuePauseQueueResponse), 'PurgeQueue': (taskqueue_service_pb.TaskQueuePurgeQueueRequest, taskqueue_service_pb.TaskQueuePurgeQueueResponse), 'DeleteQueue': (taskqueue_service_pb.TaskQueueDeleteQueueRequest, taskqueue_service_pb.TaskQueueDeleteQueueResponse), 'DeleteGroup': (taskqueue_service_pb.TaskQueueDeleteGroupRequest, taskqueue_service_pb.TaskQueueDeleteGroupResponse), 'QueryTasks': (taskqueue_service_pb.TaskQueueQueryTasksRequest, taskqueue_service_pb.TaskQueueQueryTasksResponse), 'FetchTask': (taskqueue_service_pb.TaskQueueFetchTaskRequest, taskqueue_service_pb.TaskQueueFetchTaskResponse), 'QueryAndOwnTasks': ( taskqueue_service_pb.TaskQueueQueryAndOwnTasksRequest, taskqueue_service_pb.TaskQueueQueryAndOwnTasksResponse), 'ModifyTaskLease': ( taskqueue_service_pb.TaskQueueModifyTaskLeaseRequest, taskqueue_service_pb.TaskQueueModifyTaskLeaseResponse), 'UpdateStorageLimit': ( taskqueue_service_pb.TaskQueueUpdateStorageLimitRequest, taskqueue_service_pb.TaskQueueUpdateStorageLimitResponse), }, 'urlfetch': { 'Fetch': (urlfetch_service_pb.URLFetchRequest, urlfetch_service_pb.URLFetchResponse), }, 'user': { 'CreateLoginURL': (user_service_pb.CreateLoginURLRequest, user_service_pb.CreateLoginURLResponse), 'CreateLogoutURL': (user_service_pb.CreateLogoutURLRequest, user_service_pb.CreateLogoutURLResponse), 'GetOAuthUser': (user_service_pb.GetOAuthUserRequest, user_service_pb.GetOAuthUserResponse), 'CheckOAuthSignature': (user_service_pb.CheckOAuthSignatureRequest, user_service_pb.CheckOAuthSignatureResponse), }, 'xmpp': { 'GetPresence': (xmpp_service_pb.PresenceRequest, xmpp_service_pb.PresenceResponse), 'BulkGetPresence': (xmpp_service_pb.BulkPresenceRequest, xmpp_service_pb.BulkPresenceResponse), 'SendMessage': (xmpp_service_pb.XmppMessageRequest, xmpp_service_pb.XmppMessageResponse), 'SendInvite': (xmpp_service_pb.XmppInviteRequest, xmpp_service_pb.XmppInviteResponse), 'SendPresence': (xmpp_service_pb.XmppSendPresenceRequest, xmpp_service_pb.XmppSendPresenceResponse), 'CreateChannel': (channel_service_pb.CreateChannelRequest, channel_service_pb.CreateChannelResponse), 'SendChannelMessage': (channel_service_pb.SendMessageRequest, api_base_pb.VoidProto), }, }