api.boxes.$deviceId.data.ts

import { type ActionFunction, type ActionFunctionArgs } from "react-router";
import { postNewMeasurements } from "~/lib/measurement-service.server";
import { StandardResponse } from "~/utils/response-utils";

export const action: ActionFunction = async ({
  request,
  params,
}: ActionFunctionArgs): Promise<Response> => {
  try {
    const deviceId = params.deviceId;
    if (deviceId === undefined)
      return StandardResponse.badRequest("Invalid device id specified");

    const searchParams = new URL(request.url).searchParams;
    const luftdaten = searchParams.get("luftdaten") !== null;
    const hackair = searchParams.get("hackair") !== null;

    const contentType = request.headers.get("content-type") || "";
    const authorization = request.headers.get("authorization");

    let body: any;
    if (contentType.includes("application/json")) {
      body = await request.json();
    } else if (contentType.includes("text/csv")) {
      body = await request.text();
    } else if (contentType.includes("application/sbx-bytes")) {
      body = await request.arrayBuffer();
    } else {
      body = await request.text();
    }

    await postNewMeasurements(deviceId, body, {
      contentType,
      luftdaten,
      hackair,
      authorization,
    });

    return new Response("Measurements saved in box", {
      status: 201,
      headers: {
        "Content-Type": "text/plain; charset=utf-8",
      },
    });
  } catch (err: any) {
    // Handle different error types
    if (err.name === "UnauthorizedError")
      return StandardResponse.unauthorized(err.message);

    if (err.name === "ModelError" && err.type === "UnprocessableEntityError")
      return StandardResponse.unprocessableContent(err.message);

    if (err.name === "UnsupportedMediaTypeError")
      return StandardResponse.unsupportedMediaType(err.message);

    return StandardResponse.internalServerError(err.message || "An unexpected error occurred");
  }
};