Merge pull request #1796 from serlo/staging

Deployment

.github/workflows/push-migration-image.yml

@@ -19,7 +19,7 @@ jobs:
       - name: Build and push Docker image
         run: |
           cd packages/db-migrations
-          DOCKER_REGISTRY=ghcr.io DOCKER_REPOSITORY=$(echo $GITHUB_REPOSITORY)/db-migration lerna run --stream push-image
+          DOCKER_REGISTRY=ghcr.io DOCKER_REPOSITORY=$(echo $GITHUB_REPOSITORY)/db-migration yarn push-image
         env:
           DOCKER_REGISTRY: ghcr.io
           DOCKER_REPOSITORY: ${{ github.repository }}/db-migration

__tests__/schema/user/add-role.ts

@@ -127,6 +127,26 @@ test('updates the cache', async () => {
   })
 })
 
+test('Is successful even when user has already role', async () => {
+  await uuidQuery.shouldReturnData({
+    uuid: {
+      roles: {
+        nodes: [{ role: Role.Login, scope: Scope.Serlo }],
+      },
+    },
+  })
+  await mutation
+    .withInput({ username: regularUser.username, role: Role.Login })
+    .execute()
+  await uuidQuery.shouldReturnData({
+    uuid: {
+      roles: {
+        nodes: [{ role: Role.Login, scope: Scope.Serlo }],
+      },
+    },
+  })
+})
+
 test('fails when user is not authenticated', async () => {
   await mutation.forUnauthenticatedUser().shouldFailWithError('UNAUTHENTICATED')
 })

packages/server/src/schema/uuid/user/resolvers.ts

@@ -321,20 +321,29 @@ export const resolvers: Resolvers = {
         throw new UserInputError('no user with given username')
       }
 
+      const userHasAlreadyRole = await database.fetchOptional(
+        `
+        SELECT 1
+          FROM role_user
+          WHERE user_id = ? 
+          AND role_id = ( SELECT id
+            FROM role
+            WHERE name = ?)`,
+        [id, generateRole(role, instance)],
+      )
+
+      if (userHasAlreadyRole) {
+        return { success: true, query: {} }
+      }
+
       await database.mutate(
         `
         INSERT INTO role_user (user_id, role_id)
         SELECT ?, role.id
         FROM role
         WHERE role.name = ?
-        AND NOT EXISTS (
-          SELECT 1
-          FROM role_user
-          WHERE role_user.user_id = ?
-          AND role_user.role_id = role.id
-        )
         `,
-        [id, generateRole(role, instance), id],
+        [id, generateRole(role, instance)],
       )
 
       await UuidResolver.removeCacheEntry({ id }, context)