2

我正在尝试为 amqplib npm 包编写一个 reasonml 绑定：

http://www.squaremobius.net/amqp.node/

特别是这个功能：

http://www.squaremobius.net/amqp.node/channel_api.html#channel_get

class type amqpMessageT = [@bs] {
  pub content: nodeBuffer
};

type amqpMessage = Js.t(amqpMessageT);

type gottenMessage = Js.Nullable.t(amqpMessage);

type qualifiedMessage = Message(gottenMessage) | Boolean(bool);

class type amqpChannelT = [@bs] {
  pub assertQueue: string => queueParams => Js.Promise.t(unit);
  pub consume: string => (amqpMessage => unit) => unit;
  pub ack: amqpMessage => unit;
  pub get: string => Js.Promise.t(qualifiedMessage);
  pub purgeQueue: string => Js.Promise.t(unit);
  pub deleteQueue: string => Js.Promise.t(unit);
  pub sendToQueue: string => nodeBuffer => messageParams => unit;
};

然后我有以下代码：

 ....
 channel##get("MyQueue")
 |> Js.Promise.then_(message => {
   switch message {
     | Boolean(false) => Js.Promise.resolve(Js.log("No Message"));
     | Message(msg) => Js.Promise.resolve(Js.log("Has Message, Will Travel"));
     | Boolean(true) => Js.Promise.resolve(Js.log("Impossible Message"!));
   }
  }

但是，即使 js 调用返回 false，这始终会沿着“Message(msg)”路径向下移动。

现在添加以下绑定：

let unsafeGet: amqpChannel => string => Js.Promise.t(gottenMessage) = [%bs.raw{|function(channel, queueName) {
  return channel.get(queueName).then((value) => {
    if(value === false) {
      return Promise.resolve(null)
    } else {
      return Promise.resolve(value)
    }
  })
}|}];

我已经能够回避这个问题，但bs.raw如果我诚实的话，我并不是非常喜欢使用它。我最初的未标记联合类型有什么问题？我该如何解决这个问题？

4

1 回答 1

4

OCaml 语言中没有未标记的联合类型，也没有运行时类型信息，因此您必须实现自己的类型、检查和转换才能将其转换为可用的形式。

例如，您可以使用抽象类型来表示“未知”类型，并使用伴随函数来检查其类型，将其强制转换为该类型，然后将其转换为qualifiedMessage：

type unknownMessage;

let classifyMessage = (value: unknownMessage) =>
  switch (Js.Types.classify(value)) {
  | JSString(s) => Message(Js.Nullable.return(s))
  | JSNull      => Message(Js.null)
  | JSFalse     => Boolean(false)
  | JSTrue      => Boolean(true)
  | _           => failwith("invalid runtime type")
  }

此外，作为旁注，如果您通过公开抽象类型和函数/外部而不是公开“原始”对象来抽象出底层数据结构，您将在如何定义接口方面获得很大的灵活性，并且可以隐藏这种额外的转换步。

于 2018-07-30T20:07:56.387 回答