main.ts

// oxlint-disable no-console -- This example prints its observable output to stdout.
import { readFileSync, unlinkSync, writeFileSync } from 'node:fs';
import { unreachable } from '../generated/common';
import { SendEmailRequest, SendEmailResponse } from '../generated/types';

const requestFilePath = '/tmp/request';
const responseFilePath = '/tmp/response';

function writeToFiles(): void {
  const requestMessage = {
    to: 'typical@example.com',
    subject: 'I love Typical!',
    body: 'It makes serialization easy and safe.',
  };

  const responseMessage = {
    error: 'Example error',
  };

  const requestArrayBuffer = SendEmailRequest.serialize(requestMessage);
  writeFileSync(requestFilePath, new Uint8Array(requestArrayBuffer));

  const responseArrayBuffer = SendEmailResponse.serialize(responseMessage);
  writeFileSync(responseFilePath, new Uint8Array(responseArrayBuffer));
}

function readFromFiles(): void {
  const requestFileContents = readFileSync(requestFilePath);
  const requestMessage = SendEmailRequest.deserialize(new Uint8Array(requestFileContents));
  if (requestMessage instanceof Error) {
    throw requestMessage;
  }

  const responseFileContents = readFileSync(responseFilePath);
  const responseMessage = SendEmailResponse.deserialize(new Uint8Array(responseFileContents));
  if (responseMessage instanceof Error) {
    throw responseMessage;
  }

  console.log('to:', requestMessage.to);
  console.log('subject:', requestMessage.subject);
  console.log('body:', requestMessage.body);

  switch (responseMessage.$field) {
    case 'success':
      console.log('The email was sent!');
      break;
    case 'error':
      console.log('An error occurred:', responseMessage.error);
      break;
    default:
      return unreachable(responseMessage);
  }
}

writeToFiles();
readFromFiles();
unlinkSync(requestFilePath);
unlinkSync(responseFilePath);