Throws when trying to set a records field that has a dot in the key

Author: nfrade

client/src/set/fieldParsers/record.ts

@@ -19,6 +19,10 @@ export default async (
 
   const fn = fieldParsers[fields.values.type]
 
+  if (Object.keys(payload).filter((key) => /\./g.test(key)).length) {
+    throw new Error('Cannot use "." in a record key')
+  }
+
   if (payload.$delete) {
     result.push('7', field, '')
     return 0

client/src/set/validate.ts

@@ -65,7 +65,13 @@ export default async function parseSetObject(
 
   //  && (<any>payload.parents).$noRoot
   const isNonEmpty = (v: any): boolean => !!(v && v.length)
-  if (payload.parents && (payload.parents['$noRoot'] || Array.isArray(payload.parents) || payload.parents.$value || isNonEmpty(payload.parents['$add']))) {
+  if (
+    payload.parents &&
+    (payload.parents['$noRoot'] ||
+      Array.isArray(payload.parents) ||
+      payload.parents.$value ||
+      isNonEmpty(payload.parents['$add']))
+  ) {
     result[0] += 'N'
   }
 

client/test/record.ts

@@ -21,6 +21,7 @@ test.before(async (t) => {
         },
       },
       hello: {
+        prefix: 'he',
         fields: {
           name: { type: 'string' },
           members: {
@@ -48,7 +49,7 @@ test.after(async (t) => {
   await t.connectionsAreEmpty()
 })
 
-test.serial('remove object from record', async (t) => {
+test.serial.failing('remove object from record', async (t) => {
   const client = connect({ port: port })
 
   const thingId = await client.set({
@@ -110,3 +111,42 @@ test.serial('remove object from record', async (t) => {
 
   await client.destroy()
 })
+
+test.serial('fail when setting key with a dot', async (t) => {
+  const client = connect({ port: port })
+
+  await client.set({
+    $id: 'he111111',
+    members: {
+      'Very long first': {
+        x: 'first',
+      },
+    },
+  })
+
+  t.throwsAsync(
+    client.set({
+      $id: 'he111111',
+      name: 'derp',
+      members: {
+        hallo: {
+          x: 'hallo',
+        },
+        '1.yeye': {
+          x: 'doei',
+        },
+      },
+    })
+  )
+  await wait(200)
+
+  t.deepEqual(await client.get({ $id: 'he111111', members: true }), {
+    members: {
+      'Very long first': {
+        x: 'first',
+      },
+    },
+  })
+
+  await client.destroy()
+})