diff --git a/packages/contact/create-table.js b/packages/contact/create-table.js
new file mode 100644
index 0000000..144c50b
--- /dev/null
+++ b/packages/contact/create-table.js
@@ -0,0 +1,65 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+//--kind nodejs:default
+//--param POSTGRES_URL $POSTGRES_URL
+
+const { Client } = require('pg')
+
+async function main(args) {
+    console.log('Starting create-table action')
+    const client = new Client({ connectionString: args.POSTGRES_URL });
+
+    const createSchema = `CREATE SCHEMA IF NOT EXISTS demo;`
+
+    const createTable = `
+    CREATE TABLE IF NOT EXISTS demo.contacts (
+        id serial PRIMARY KEY,
+        name varchar(50),
+        email varchar(50),
+        phone varchar(50),
+        message varchar(300)
+    );
+    `
+
+    try {
+        console.log(`Connecting to ${args.POSTGRES_URL}`);
+        await client.connect();
+        console.log('Connected to database');
+        await client.query(createSchema);
+        console.log('Schema demo created');
+        await client.query(createTable);
+        console.log('Contact table created');
+        return { result: 'OK' };
+    } catch (e) {
+        if (e instanceof AggregateError) {
+            for (const err of e.errors) {
+                console.error('[ERROR] - ', err.message || err);
+            }
+        } else if (e instanceof Error) {
+            console.error('[ERROR]  - ', e.message);
+        } else {
+            console.error('[ERROR] - ', e);
+        }
+        return { result: 'ERROR' };
+    } finally {
+        console.log('Closing connection');
+        if (client) {
+            await client.end();
+        }
+    }
+}
diff --git a/packages/contact/write.js b/packages/contact/write.js
new file mode 100644
index 0000000..c98c2ba
--- /dev/null
+++ b/packages/contact/write.js
@@ -0,0 +1,51 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+//--kind nodejs:default
+//--param POSTGRES_URL $POSTGRES_URL
+
+const {Client} = require('pg')
+
+async function main(args) {
+    const client = new Client({connectionString: args.POSTGRES_URL});
+
+    // Connect to database server
+    await client.connect();
+
+    const {name, email, phone, message} = args;
+
+    try {
+        let res = await client.query(
+            'INSERT INTO demo.contacts(name,email,phone,message) VALUES($1,$2,$3,$4)',
+            [name, email, phone, message]
+        );
+        console.log(res);
+    } catch (e) {
+        console.log(e);
+        throw e;
+    } finally {
+        client.end();
+    }
+
+    return {
+        body: args.body,
+        name,
+        email,
+        phone,
+        message
+    };
+}
diff --git a/web/index.html b/web/index.html
index b00a1d0..2521b40 100644
--- a/web/index.html
+++ b/web/index.html
@@ -33,7 +33,7 @@
     <div class="w-50 p-4 border rounded bg-light shadow">
         <h2 class="text-center mb-4">Get In Touch</h2>
         
-        <form method="POST" action="/api/v1/web/opstutorial/contact/submit" enctype="application/x-www-form-urlencoded">
+        <form method="POST" action="/api/v1/web/opstutorial/contact/submit-write" enctype="application/x-www-form-urlencoded">
             <div class="mb-3">
                 <label for="name" class="form-label">Name</label>
                 <input type="text" class="form-control" id="name" name="name" placeholder="Insert your name">