render(view: string, options?: object, callback?: (err: Error, html: string) => void): void;

app.post("/posts", async (req, res) => {
  const { title, body, createdById, password } = req.body as PostOption;
  if (!body) {
    return res.status(400).send("本文を入力してください");
  }
  if (body.length > 1200) {
    return res.status(400).send("本文は1200字までです");
  }
  if (title && title.length > 50) {
    return res.status(400).send("タイトルは50字までです");
  }
  if (!createdById) {
    return res.status(400).send("ユーザidが提供されませんでした");
  }
  const userRecord = await admin
    .auth()
    .getUser(createdById)
    .catch(error => {
      console.error({ error });
      return null;
    });
  if (!userRecord) {
    return res.status(400).send(`ユーザ: ${createdById}は存在しません`);
  }
  if (!password) {
    return res.status(400).send("パスワードが設定されていません");
  }
  if (password.length < 8) {
    return res
      .status(400)
      .send("パスワードが短すぎます。8文字以上にしてください。");
  }
  const passwordHash = await bcryptjs.hash(password, 10);

  const doc = await db.collection("/posts").add({
    title,
    body,
    createdById,
    passwordHash
  } as FSPost);
  const snapshot = await doc.get();
  const data = snapshot.data();
  if (!data) {
    return res.status(500).send("投稿の作成に失敗しました");
  }
  const { id } = doc;

  const bucket = admin.storage().bucket();
  const bucketName = bucket.name;
  // 投稿を編集したらプレビュー画像も変更されるようにしたいので、プレビュー画像は投稿のidから一意に決まるようにする
  const fileName = `${id}.png`;
  const previewUrl = `https://storage.googleapis.com/${bucketName}/${fileName}`;
  const bufferOrError = await generatePreview(body).catch(err => {
    console.error({ err });
    return new Error("プレビュー画像の生成に失敗しました");
  });
  if (bufferOrError instanceof Error) {
    return res.status(500).send(bufferOrError.message);
  }
  const tmpPath = join(tmpdir(), `${id}.png`);
  writeFileSync(tmpPath, bufferOrError);
  await bucket
    .upload(tmpPath, {
      metadata: { contentType: "image/png" },
      public: true
    })
    .catch(err => {
      console.log({ err });
      return res.status(500).send("プレビュー画像のアップロードに失敗しました");
    });
  unlinkSync(tmpPath);
  await doc.set({ previewUrl } as Partial<Post>, { merge: true });
  return res.send({
    id,
    title,
    body,
    createdAt: snapshot.createTime ? snapshot.createTime.seconds : undefined,
    createdBy: extractDataFromUserRecord(userRecord),
    previewUrl
  } as Post);
});

// 前略

function badRequest<E = never>(
message: string
): H.Middleware<H.StatusOpen, H.ResponseEnded, E, void> {
return pipe(
  H.status(H.Status.BadRequest),
  H.ichain(() => H.closeHeaders()),
  H.ichain(() => H.send(message))
);
}

function notFound<E = never>(
message: string
): H.Middleware<H.StatusOpen, H.ResponseEnded, E, void> {
return pipe(
  H.status(H.Status.NotFound),
  H.ichain(() => H.closeHeaders()),
  H.ichain(() => H.send(message))
);
}

function serverError<E = never>(
message: string
): H.Middleware<H.StatusOpen, H.ResponseEnded, E, void> {
return pipe(
  H.status(H.Status.ServerError),
  H.ichain(() => H.closeHeaders()),
  H.ichain(() => H.send(message))
);
}

const sendError = (
err: TweetURLError | typeof FailedToGenerateImage
): H.Middleware<H.StatusOpen, H.ResponseEnded, never, void> => {
switch (err) {
  case 'TweetNotFound':
    return notFound(TweetNotFoundMessage);
  case 'InvalidArguments':
    return badRequest(InvalidRequestMessage);
  case 'FailedToGenerateImage':
    return serverError(InternalServerErrorMessage);
}
};

// returns a middleware validating `req.param.tweetURL`
const m = t.interface({
  tweetURL: TweetURL
});
const decoded = H.decodeQuery(m.decode);

const parseTweetURLFromQueryMiddleware = pipe(
  decoded,
  H.mapLeft<t.Errors, ServerError | TweetURLError>(() => InvalidArguments)
);

const checkIfTheTweetExistsMiddleware = (query: {
  tweetURL: TweetURL;
}): H.Middleware<
  H.StatusOpen,
  H.StatusOpen,
  ServerError | TweetURLError,
  ValidatedTweetURL
> =>
  H.fromTaskEither(
    pipe(
      checkIfTheTweetExists(query.tweetURL, {
        TWITTER_BEARER_TOKEN
      }),
      TE.chain(exists =>
        exists
          ? TE.right(query.tweetURL as ValidatedTweetURL)
          : TE.left(TweetNotFound)
      )
    )
  );

const mapTweetURLToImage = (
  url: ValidatedTweetURL
): H.Middleware<
  H.StatusOpen,
  H.StatusOpen,
  ServerError | TweetURLError,
  Buffer
> =>
  H.fromTaskEither(
    pipe(
      generateImage(url),
      TE.mapLeft(e => FailedToGenerateImage)
    )
  );

const respondWithImage = (
  imgBuffer: Buffer
): H.Middleware<
  H.StatusOpen,
  H.ResponseEnded,
  ServerError | TweetURLError,
  void
> =>
  pipe(
    H.status(H.Status.OK),
    H.ichain(() =>
      H.header('Content-disposition', `inline; filename="${new Date()}.png"`)
    ),
    H.ichain(() => H.contentType(H.MediaType.imagePNG)),
    H.ichain(() => H.closeHeaders()),
    H.ichain(() => H.send(imgBuffer))
  );

const getImage = pipe(
  parseTweetURLFromQueryMiddleware,
  H.ichain(checkIfTheTweetExistsMiddleware),
  H.ichain(mapTweetURLToImage),
  H.ichain(respondWithImage)
);

app.get(
  '/img',
  toRequestHandler(
    pipe(
      getImage,
      H.orElse(sendError)
    )
  )
);