update applicationapi to use ResolvedHost

GitOrigin-RevId: c3622368e13b6298b724b04187417dbc1d6b8da7

Author: gautamg795

crates/application/src/api.rs

@@ -10,10 +10,12 @@ use common::{
         CanonicalizedComponentFunctionPath,
         ComponentId,
     },
+    http::ResolvedHost,
     pause::PauseClient,
     runtime::Runtime,
     types::{
         AllowedVisibility,
+        ConvexOrigin,
         FunctionCaller,
         RepeatableTimestamp,
     },
@@ -89,14 +91,14 @@ pub enum ExecuteQueryTimestamp {
 pub trait ApplicationApi: Send + Sync {
     async fn authenticate(
         &self,
-        host: &str,
+        host: &ResolvedHost,
         request_id: RequestId,
         auth_token: AuthenticationToken,
     ) -> anyhow::Result<Identity>;
 
     async fn execute_public_query(
         &self,
-        host: &str,
+        host: &ResolvedHost,
         request_id: RequestId,
         identity: Identity,
         path: CanonicalizedComponentFunctionPath,
@@ -108,7 +110,7 @@ pub trait ApplicationApi: Send + Sync {
 
     async fn execute_public_mutation(
         &self,
-        host: &str,
+        host: &ResolvedHost,
         request_id: RequestId,
         identity: Identity,
         path: CanonicalizedComponentFunctionPath,
@@ -120,7 +122,7 @@ pub trait ApplicationApi: Send + Sync {
 
     async fn execute_public_action(
         &self,
-        host: &str,
+        host: &ResolvedHost,
         request_id: RequestId,
         identity: Identity,
         path: CanonicalizedComponentFunctionPath,
@@ -130,7 +132,7 @@ pub trait ApplicationApi: Send + Sync {
 
     async fn execute_any_function(
         &self,
-        host: &str,
+        host: &ResolvedHost,
         request_id: RequestId,
         identity: Identity,
         path: CanonicalizedComponentFunctionPath,
@@ -140,13 +142,13 @@ pub trait ApplicationApi: Send + Sync {
 
     async fn latest_timestamp(
         &self,
-        host: &str,
+        host: &ResolvedHost,
         request_id: RequestId,
     ) -> anyhow::Result<RepeatableTimestamp>;
 
     async fn execute_http_action(
         &self,
-        host: &str,
+        host: &ResolvedHost,
         request_id: RequestId,
         http_request_metadata: HttpActionRequest,
         identity: Identity,
@@ -156,16 +158,17 @@ pub trait ApplicationApi: Send + Sync {
 
     async fn check_store_file_authorization(
         &self,
-        host: &str,
+        host: &ResolvedHost,
         request_id: RequestId,
         token: &str,
         validity: Duration,
     ) -> anyhow::Result<ComponentId>;
 
     async fn store_file(
         &self,
-        host: &str,
+        host: &ResolvedHost,
         request_id: RequestId,
+        origin: ConvexOrigin,
         component: ComponentId,
         content_length: Option<ContentLength>,
         content_type: Option<ContentType>,
@@ -175,17 +178,19 @@ pub trait ApplicationApi: Send + Sync {
 
     async fn get_file_range(
         &self,
-        host: &str,
+        host: &ResolvedHost,
         request_id: RequestId,
+        origin: ConvexOrigin,
         component: ComponentId,
         file_storage_id: FileStorageId,
         range: (Bound<u64>, Bound<u64>),
     ) -> anyhow::Result<FileRangeStream>;
 
     async fn get_file(
         &self,
-        host: &str,
+        host: &ResolvedHost,
         request_id: RequestId,
+        origin: ConvexOrigin,
         component: ComponentId,
         file_storage_id: FileStorageId,
     ) -> anyhow::Result<FileStream>;
@@ -197,15 +202,18 @@ pub trait ApplicationApi: Send + Sync {
     // socket connection. NOTE: We might eventually strengthen the requirement for
     // the implementation and require it to reconnect internally but easier to
     // start this way.
-    async fn subscription_client(&self, host: &str) -> anyhow::Result<Box<dyn SubscriptionClient>>;
+    async fn subscription_client(
+        &self,
+        host: &ResolvedHost,
+    ) -> anyhow::Result<Box<dyn SubscriptionClient>>;
 }
 
 // Implements ApplicationApi via Application.
 #[async_trait]
 impl<RT: Runtime> ApplicationApi for Application<RT> {
     async fn authenticate(
         &self,
-        _host: &str,
+        _host: &ResolvedHost,
         _request_id: RequestId,
         auth_token: AuthenticationToken,
     ) -> anyhow::Result<Identity> {
@@ -215,7 +223,7 @@ impl<RT: Runtime> ApplicationApi for Application<RT> {
 
     async fn execute_public_query(
         &self,
-        _host: &str,
+        _host: &ResolvedHost,
         request_id: RequestId,
         identity: Identity,
         path: CanonicalizedComponentFunctionPath,
@@ -239,7 +247,7 @@ impl<RT: Runtime> ApplicationApi for Application<RT> {
 
     async fn execute_public_mutation(
         &self,
-        _host: &str,
+        _host: &ResolvedHost,
         request_id: RequestId,
         identity: Identity,
         path: CanonicalizedComponentFunctionPath,
@@ -267,7 +275,7 @@ impl<RT: Runtime> ApplicationApi for Application<RT> {
 
     async fn execute_public_action(
         &self,
-        _host: &str,
+        _host: &ResolvedHost,
         request_id: RequestId,
         identity: Identity,
         path: CanonicalizedComponentFunctionPath,
@@ -285,7 +293,7 @@ impl<RT: Runtime> ApplicationApi for Application<RT> {
 
     async fn execute_any_function(
         &self,
-        _host: &str,
+        _host: &ResolvedHost,
         request_id: RequestId,
         identity: Identity,
         path: CanonicalizedComponentFunctionPath,
@@ -297,15 +305,15 @@ impl<RT: Runtime> ApplicationApi for Application<RT> {
 
     async fn latest_timestamp(
         &self,
-        _host: &str,
+        _host: &ResolvedHost,
         _request_id: RequestId,
     ) -> anyhow::Result<RepeatableTimestamp> {
         Ok(self.now_ts_for_reads())
     }
 
     async fn execute_http_action(
         &self,
-        _host: &str,
+        _host: &ResolvedHost,
         request_id: RequestId,
         http_request_metadata: HttpActionRequest,
         identity: Identity,
@@ -324,7 +332,7 @@ impl<RT: Runtime> ApplicationApi for Application<RT> {
 
     async fn check_store_file_authorization(
         &self,
-        _host: &str,
+        _host: &ResolvedHost,
         _request_id: RequestId,
         token: &str,
         validity: Duration,
@@ -335,8 +343,9 @@ impl<RT: Runtime> ApplicationApi for Application<RT> {
 
     async fn store_file(
         &self,
-        _host: &str,
+        _host: &ResolvedHost,
         _request_id: RequestId,
+        _origin: ConvexOrigin,
         component: ComponentId,
         content_length: Option<ContentLength>,
         content_type: Option<ContentType>,
@@ -355,8 +364,9 @@ impl<RT: Runtime> ApplicationApi for Application<RT> {
 
     async fn get_file_range(
         &self,
-        _host: &str,
+        _host: &ResolvedHost,
         _request_id: RequestId,
+        _origin: ConvexOrigin,
         component: ComponentId,
         file_storage_id: FileStorageId,
         range: (Bound<u64>, Bound<u64>),
@@ -366,8 +376,9 @@ impl<RT: Runtime> ApplicationApi for Application<RT> {
 
     async fn get_file(
         &self,
-        _host: &str,
+        _host: &ResolvedHost,
         _request_id: RequestId,
+        _origin: ConvexOrigin,
         component: ComponentId,
         file_storage_id: FileStorageId,
     ) -> anyhow::Result<FileStream> {
@@ -376,7 +387,7 @@ impl<RT: Runtime> ApplicationApi for Application<RT> {
 
     async fn subscription_client(
         &self,
-        _host: &str,
+        _host: &ResolvedHost,
     ) -> anyhow::Result<Box<dyn SubscriptionClient>> {
         Ok(Box::new(ApplicationSubscriptionClient {
             database: self.database.clone(),