feat: opportunity map europe (#3389)

Author: capJavert

__tests__/helpers.ts

@@ -453,7 +453,11 @@ export const doNotFake: FakeableAPI[] = [
   'clearTimeout',
 ];
 
-export const createMockBrokkrTransport = () =>
+export const createMockBrokkrTransport = ({
+  opportunity,
+}: {
+  opportunity?: Partial<ParseOpportunityResponse['opportunity']>;
+} = {}) =>
   createRouterTransport(({ service }) => {
     service(BrokkrService, {
       extractMarkdown: (request) => {
@@ -527,6 +531,7 @@ export const createMockBrokkrTransport = () =>
                   'This is the interview process of the mocked opportunity.',
               }),
             }),
+            ...opportunity,
           }),
         });
       },

__tests__/schema/opportunity.ts

@@ -60,6 +60,7 @@ import {
   OpportunityType,
   SalaryPeriod,
   SeniorityLevel,
+  Location,
 } from '@dailydotdev/schema';
 import { UserCandidatePreference } from '../../src/entity/user/UserCandidatePreference';
 import { QuestionScreening } from '../../src/entity/questions/QuestionScreening';
@@ -5625,8 +5626,6 @@ describe('mutation parseOpportunity', () => {
 
     deleteFileFromBucketSpy.mockResolvedValue(true);
 
-    console.log(await con.getRepository(OpportunityUserRecruiter).find());
-
     // Execute the mutation with a file upload
     const res = await authorizeRequest(
       request(app.server)
@@ -5664,6 +5663,106 @@ describe('mutation parseOpportunity', () => {
       '550e8400-e29b-41d4-a716-446655440000',
     );
   });
+
+  it('should assign opportunity location to Europe when no country specified', async () => {
+    loggedUser = '1';
+
+    fileTypeFromBuffer.mockResolvedValue({
+      ext: 'pdf',
+      mime: 'application/pdf',
+    });
+
+    const uploadResumeFromBufferSpy = jest.spyOn(
+      googleCloud,
+      'uploadResumeFromBuffer',
+    );
+
+    uploadResumeFromBufferSpy.mockResolvedValue(
+      `https://storage.cloud.google.com/${RESUME_BUCKET_NAME}/file`,
+    );
+
+    const deleteFileFromBucketSpy = jest.spyOn(
+      googleCloud,
+      'deleteFileFromBucket',
+    );
+
+    deleteFileFromBucketSpy.mockResolvedValue(true);
+
+    const transport = createMockBrokkrTransport({
+      opportunity: {
+        location: [
+          new Location({
+            continent: 'Europe',
+            type: 1,
+          }),
+        ],
+      },
+    });
+
+    const serviceClient = {
+      instance: createClient(BrokkrService, transport),
+      garmr: createGarmrMock(),
+    };
+
+    jest
+      .spyOn(brokkrCommon, 'getBrokkrClient')
+      .mockImplementation((): ServiceClient<typeof BrokkrService> => {
+        return serviceClient;
+      });
+
+    await saveFixtures(con, DatasetLocation, [
+      {
+        country: 'Europe',
+        iso2: 'EU',
+        iso3: 'EUR',
+      },
+    ]);
+
+    // Execute the mutation with a file upload
+    const res = await authorizeRequest(
+      request(app.server)
+        .post('/graphql')
+        .field(
+          'operations',
+          JSON.stringify({
+            query: MUTATION,
+            variables: {
+              payload: {
+                file: null,
+              },
+            },
+          }),
+        )
+        .field('map', JSON.stringify({ '0': ['variables.payload.file'] }))
+        .attach('0', './__tests__/fixture/screen.pdf'),
+    ).expect(200);
+
+    const body = res.body;
+    expect(body.errors).toBeFalsy();
+
+    expect(body.data.parseOpportunity).toMatchObject({
+      locations: [
+        {
+          location: {
+            city: null,
+            country: 'Europe',
+            subdivision: null,
+          },
+          type: 1,
+        },
+      ],
+    });
+
+    const opportunity = await con.getRepository(OpportunityJob).findOne({
+      where: {
+        id: body.data.parseOpportunity.id,
+      },
+    });
+
+    expect(opportunity!.organizationId).toBe(
+      '550e8400-e29b-41d4-a716-446655440000',
+    );
+  });
 });
 
 describe('mutation createSharedSlackChannel', () => {

src/common/opportunity/parse.ts

@@ -205,6 +205,17 @@ export async function parseOpportunityWithBrokkr(
       location: Array.isArray(result.opportunity?.location)
         ? result.opportunity.location
             .map((loc) => {
+              if (
+                !loc.country &&
+                loc.continent?.toLowerCase().trim() === 'europe'
+              ) {
+                return {
+                  ...loc,
+                  country: 'Europe',
+                  iso2: 'EU',
+                };
+              }
+
               // Jobs may indicate Remote Europe with no country
               if (!loc?.country?.trim() && loc?.continent?.trim()) {
                 return {

src/common/schema/opportunities.ts

@@ -17,7 +17,7 @@ export const createOpportunityEditContentSchema = ({
 }: {
   optional?: boolean;
 } = {}) => {
-  const contentSchema = z.string().max(2000);
+  const contentSchema = z.string().max(2500);
 
   return z.object({
     content: optional ? contentSchema.optional() : contentSchema.nonempty(),

src/schema/opportunity.ts

@@ -876,7 +876,7 @@ export const typeDefs = /* GraphQL */ `
     Parse an opportunity from a URL or file upload
     """
     parseOpportunity(payload: ParseOpportunityInput!): Opportunity!
-      @rateLimit(limit: 5, duration: 3600)
+      @rateLimit(limit: 10, duration: 3600)
 
     """
     Create a shared Slack channel and invite a user by email