implement shim'd getAuthenticatedUser

Author: AlexTugarev

components/dashboard/src/service/json-rpc-user-client.ts

@@ -6,14 +6,19 @@
 
 import { UserService } from "@gitpod/public-api/lib/gitpod/v1/user_connect";
 
-import { Code, ConnectError, PromiseClient } from "@connectrpc/connect";
+import { PromiseClient } from "@connectrpc/connect";
 import { PartialMessage } from "@bufbuild/protobuf";
 import { GetAuthenticatedUserRequest, GetAuthenticatedUserResponse } from "@gitpod/public-api/lib/gitpod/v1/user_pb";
+import { getGitpodService } from "./service";
+import { converter } from "./public-api";
 
 export class JsonRpcUserClient implements PromiseClient<typeof UserService> {
     async getAuthenticatedUser(
         request: PartialMessage<GetAuthenticatedUserRequest>,
     ): Promise<GetAuthenticatedUserResponse> {
-        throw new ConnectError("unimplemented", Code.Unimplemented);
+        const user = await getGitpodService().server.getLoggedInUser();
+        return new GetAuthenticatedUserResponse({
+            user: converter.toUser(user),
+        });
     }
 }

components/gitpod-protocol/src/protocol.ts

@@ -278,7 +278,7 @@ export interface AdditionalUserData extends Partial<WorkspaceTimeoutSetting> {
     workspaceAutostartOptions?: WorkspaceAutostartOption[];
 }
 
-interface WorkspaceAutostartOption {
+export interface WorkspaceAutostartOption {
     cloneURL: string;
     organizationId: string;
     workspaceClass?: string;

components/gitpod-protocol/src/public-api-converter.ts

@@ -25,6 +25,15 @@ import {
     AuthProviderType,
     OAuth2Config,
 } from "@gitpod/public-api/lib/gitpod/v1/authprovider_pb";
+import {
+    Identity,
+    User,
+    User_EmailNotificationSettings,
+    User_RoleOrPermission,
+    User_UserFeatureFlag,
+    User_WorkspaceAutostartOption,
+    User_WorkspaceTimeoutSettings,
+} from "@gitpod/public-api/lib/gitpod/v1/user_pb";
 import {
     BranchMatchingStrategy,
     Configuration,
@@ -73,6 +82,8 @@ import {
     UnauthorizedRepositoryAccessError,
 } from "./messaging/error";
 import {
+    User as UserProtocol,
+    Identity as IdentityProtocol,
     AuthProviderEntry as AuthProviderProtocol,
     AuthProviderInfo,
     CommitContext,
@@ -89,6 +100,9 @@ import {
     Token,
     SuggestedRepository as SuggestedRepositoryProtocol,
     UserSSHPublicKeyValue,
+    NamedWorkspaceFeatureFlag,
+    WorkspaceAutostartOption,
+    IDESettings,
 } from "./protocol";
 import {
     OrgMemberInfo,
@@ -109,6 +123,7 @@ import {
 } from "./workspace-instance";
 import { Author, Commit } from "@gitpod/public-api/lib/gitpod/v1/scm_pb";
 import type { DeepPartial } from "./util/deep-partial";
+import { RoleOrPermission } from "./permission";
 
 export type PartialConfiguration = DeepPartial<Configuration> & Pick<Configuration, "id">;
 
@@ -910,4 +925,138 @@ export class PublicAPIConverter {
         result.lastUsedTime = Timestamp.fromDate(new Date(sshKey.lastUsedTime || sshKey.creationTime));
         return result;
     }
+
+    toUser(from: UserProtocol): User {
+        const {
+            id,
+            name,
+            creationDate,
+            identities,
+            additionalData,
+            avatarUrl,
+            featureFlags,
+            organizationId,
+            rolesOrPermissions,
+            usageAttributionId,
+            blocked,
+            lastVerificationTime,
+            verificationPhoneNumber,
+        } = from;
+        const {
+            disabledClosedTimeout,
+            dotfileRepo,
+            emailNotificationSettings,
+            ideSettings,
+            profile,
+            workspaceAutostartOptions,
+            workspaceClasses,
+            workspaceTimeout,
+        } = additionalData || {};
+
+        return new User({
+            id,
+            name,
+            createdAt: this.toTimestamp(creationDate),
+            avatarUrl,
+            organizationId,
+            usageAttributionId,
+            blocked,
+            identities: identities?.map((i) => this.toIdentity(i)),
+            rolesOrPermissions: rolesOrPermissions?.map((rp) => this.toRoleOrPermission(rp)),
+            workspaceFeatureFlags: featureFlags?.permanentWSFeatureFlags?.map((ff) => this.toUserFeatureFlags(ff)),
+            timeoutSettings: new User_WorkspaceTimeoutSettings({
+                disabledClosedTimeout,
+                workspaceTimeout,
+            }),
+            dotfileRepo,
+            emailNotificationSettings: new User_EmailNotificationSettings({
+                allowsChangelogMail: emailNotificationSettings?.allowsChangelogMail,
+                allowsDevxMail: emailNotificationSettings?.allowsDevXMail,
+                allowsOnboardingMail: emailNotificationSettings?.allowsOnboardingMail,
+            }),
+            editorSettings: this.toEditorReference(ideSettings),
+            lastVerificationTime: this.toTimestamp(lastVerificationTime),
+            verificationPhoneNumber,
+            workspaceClass: workspaceClasses?.regular,
+            workspaceAutostartOptions: workspaceAutostartOptions?.map((o) => this.toWorkspaceAutostartOption(o)),
+            profile,
+        });
+    }
+
+    toTimestamp(from?: string | undefined): Timestamp | undefined {
+        return from ? Timestamp.fromDate(new Date(from)) : undefined;
+    }
+
+    toIdentity(from: IdentityProtocol): Identity {
+        const { authId, authName, authProviderId, lastSigninTime, primaryEmail } = from;
+        return new Identity({
+            authProviderId,
+            authId,
+            authName,
+            lastSigninTime: this.toTimestamp(lastSigninTime),
+            primaryEmail,
+        });
+    }
+
+    toRoleOrPermission(from: RoleOrPermission): User_RoleOrPermission {
+        switch (from) {
+            case "admin":
+                return User_RoleOrPermission.ADMIN;
+            case "devops":
+                return User_RoleOrPermission.DEVOPS;
+            case "viewer":
+                return User_RoleOrPermission.VIEWER;
+            case "developer":
+                return User_RoleOrPermission.DEVELOPER;
+            case "registry-access":
+                return User_RoleOrPermission.REGISTRY_ACCESS;
+            case "admin-permissions":
+                return User_RoleOrPermission.ADMIN_PERMISSIONS;
+            case "admin-users":
+                return User_RoleOrPermission.ADMIN_USERS;
+            case "admin-workspace-content":
+                return User_RoleOrPermission.ADMIN_WORKSPACE_CONTENT;
+            case "admin-workspaces":
+                return User_RoleOrPermission.ADMIN_WORKSPACE;
+            case "admin-projects":
+                return User_RoleOrPermission.ADMIN_PROJECTS;
+            case "new-workspace-cluster":
+                return User_RoleOrPermission.NEW_WORKSPACE_CLUSTER;
+        }
+        return User_RoleOrPermission.UNSPECIFIED;
+    }
+
+    toUserFeatureFlags(from: NamedWorkspaceFeatureFlag): User_UserFeatureFlag {
+        switch (from) {
+            case "full_workspace_backup":
+                return User_UserFeatureFlag.FULL_WORKSPACE_BACKUP;
+            case "workspace_class_limiting":
+                return User_UserFeatureFlag.WORKSPACE_CLASS_LIMITING;
+            case "workspace_connection_limiting":
+                return User_UserFeatureFlag.WORKSPACE_CONNECTION_LIMITING;
+            case "workspace_psi":
+                return User_UserFeatureFlag.WORKSPACE_PSI;
+        }
+        return User_UserFeatureFlag.UNSPECIFIED;
+    }
+
+    toEditorReference(from?: IDESettings): EditorReference | undefined {
+        if (!from) {
+            return undefined;
+        }
+        return new EditorReference({
+            name: from.defaultIde,
+            version: from.useLatestVersion ? "latest" : "stable",
+        });
+    }
+
+    toWorkspaceAutostartOption(from: WorkspaceAutostartOption): User_WorkspaceAutostartOption {
+        return new User_WorkspaceAutostartOption({
+            cloneUrl: from.cloneURL,
+            editorSettings: this.toEditorReference(from.ideSettings),
+            organizationId: from.organizationId,
+            region: from.region,
+            workspaceClass: from.workspaceClass,
+        });
+    }
 }