Ошибка EscapedSkolem при переподключении websocket в PureScript и Halogen

Question

Я пытаюсь реализовать переподключение Websocket в PureScript и совершенно не знаю, как действовать дальше. Я добавил код переподключения на верхнем уровне из-за использования Aff; Я думаю, что это правильное место, но я не уверен.

Я пытался реализовать это, как я мог бы в Haskell, но я не могу сделать это проверка типа из-за EscapedSkolem ошибка в runWs, У меня сложилось впечатление, что я могу это исправить, добавив сигнатуру типа, но я не могу на всю жизнь понять, какой может быть эта подпись!

Итак, у меня есть три вопроса:

• Это правильный способ реализации переподключения?
• Какой тип runWs (любые советы о том, как я мог бы решить это для себя, были бы фантастическими)?
• Если добавление сигнатуры типа не исправляет EscapedSkolem ошибка, как бы я исправить это?

И, наконец, я полный новичок, когда дело доходит до PureScript, поэтому, если что-то неясно, укажите это, и я постараюсь уточнить.

РЕДАКТИРОВАТЬ: Добавлен вывод компилятора ошибки и немного изменил название.

module Main where

import Prelude

import Control.Coroutine (Producer, Consumer, runProcess, consumer, ($$))
import Control.Coroutine.Aff (produce)

import Control.Monad.Aff (Aff, delay)
import Control.Monad.Aff.AVar (AVAR)
import Control.Monad.Eff (Eff)
import Control.Monad.Eff.Console (CONSOLE, log)
import Control.Monad.Eff.Exception (EXCEPTION)
import Control.Monad.Eff.Ref (REF)
import Control.Monad.Eff.Var (($=), get)

import DOM (DOM)
import DOM.Websocket.Event.CloseEvent (reason)


import Data.Either (Either(..))
import Data.Maybe (Maybe(..))
import Data.Time.Duration (Milliseconds(..))
import Halogen as H
import Halogen.Aff (HalogenEffects, awaitBody, runHalogenAff)
import Halogen.VDom.Driver (runUI)
import Log (Query(..), component)
import WebSocket (Connection(..), URL(..), WEBSOCKET, newWebSocket, runMessage, runURL, runMessageEvent)


wsURI :: URL
wsURI = URL "ws://localhost:6385"


reconnectionDelay :: Milliseconds
reconnectionDelay = Milliseconds 10000.0


main :: forall eff. Eff (HalogenEffects (console :: CONSOLE, err :: EXCEPTION , avar :: AVAR , dom :: DOM , exception :: EXCEPTION , ref :: REF , ws :: WEBSOCKET | eff)) Unit
main = do
  runHalogenAff do
    body <- awaitBody
    driver <- runUI component unit body

    ---> Replace this: <---
    runProcess (wsProducer $$ wsConsumer driver.query)
    ---> with this: <---
    --   runWs driver

-- -------------------------------------------------
-- -------------------------------------------------
--
-- Reconnection function
-- runWs :: ????????
runWs p = go
  where
    go = do
      runProcess (wsProducer $$ wsConsumer p)
      delay reconnectionDelay
      go

-- -------------------------------------------------
-- -------------------------------------------------


wsProducer :: forall eff. Producer String (Aff (console :: CONSOLE, err :: EXCEPTION , ws :: WEBSOCKET , avar :: AVAR | eff)) Unit
wsProducer = produce \emit -> do

  Connection socket <- newWebSocket wsURI []

  socket.onopen $= \event -> do
    log "onopen: Connection opened"
    log <<< runURL =<< get socket.url


  socket.onmessage $= \event -> do
    emit $ Left $ runMessage (runMessageEvent event)


  socket.onclose $= \event -> do
    log $ "Socket Closed, returning to runHalogenAff: "  <> reason event
    emit $ Right unit


  socket.onerror $= \event -> do
    log "Error."
    emit $ Right unit


wsConsumer :: forall eff . (Query ~> Aff (HalogenEffects eff)) -> Consumer String (Aff (HalogenEffects eff)) Unit
wsConsumer driver = consumer \msg -> do
  driver $ H.action $ AddMessage msg
  pure Nothing

И вывод компилятора:

Compiling Main
[1/1 MissingTypeDeclaration] src/Main.purs:54:1

      v
  54  runWs p = go
  55    where
  56      go = do
  57        runProcess (wsProducer $$ wsConsumer p)
  58        delay reconnectionDelay
  59        go
            ^

  No type declaration was provided for the top-level declaration of runWs.
  It is good practice to provide type declarations as a form of documentation.
  The inferred type of runWs was:

    forall t110 t120.
      (Query a0
      -> Aff
            ( avar :: AVAR
            , ref :: REF
            , exception :: EXCEPTION
            , dom :: DOM
            , console :: CONSOLE
            , err :: EXCEPTION
            , ws :: WEBSOCKET
            | t120
            )
            a0
      )
      -> Aff
          ( console :: CONSOLE
          , err :: EXCEPTION
          , ws :: WEBSOCKET
          , avar :: AVAR
          , dom :: DOM
          , exception :: EXCEPTION
          , ref :: REF
          | t120
          )
          t110

  where a0 is a rigid type variable
          bound at line 57, column 44 - line 57, column 45

[1/1 EscapedSkolem] src/Main.purs:54:1

      v
  54  runWs p = go
  55    where
  56      go = do
  57        runProcess (wsProducer $$ wsConsumer p)
  58        delay reconnectionDelay
  59        go
            ^

  The type variable a, bound at

    /home/rgh/dev/purescript/translate/sidebar/src/Main.purs line 57, column 44 - line 57, column 45

  has escaped its scope, appearing in the type

    (Query a2
    -> Aff
          ( avar :: AVAR
          , ref :: REF
          , exception :: EXCEPTION
          , dom :: DOM
          , console :: CONSOLE
          , err :: EXCEPTION
          , ws :: WEBSOCKET
          | t120
          )
          a2
    )
    -> Aff
        ( console :: CONSOLE
        , err :: EXCEPTION
        , ws :: WEBSOCKET
        , avar :: AVAR
        , dom :: DOM
        , exception :: EXCEPTION
        , ref :: REF
        | t120
        )
        t110

  in the expression \p ->
                      let
                        go = ...
                      in go
  in value declaration runWs

          Src   Lib   All
Warnings   1     0     1
Errors     1     0     1
* Failed to rebuild; try to fix the compile errors

Answer 1

Сообщения об ошибках компилятора иногда могут быть трудно расшифровать, но в этом случае это будет искомый ответ. Давайте посмотрим на ваш блок do здесь:

do
  runHalogenAff do
    body <- awaitBody
    driver <- runUI component unit body
    runWs driver.query -- < assuming you made a small mistake here

Я обычно начинаю с desugaring, я нахожу, что легче следовать типам, но ymmv:

runHalogenAff $
  awaitBody >>= \body ->
    runUI component unit body >>= \driver ->
      runWs driver.query

Глядя на подпись runHalogenAff мы можем видеть, что он принимает аргумент типа Aff (HalogenEffects eff) x Это означает, что следующий термин должен соответствовать значению этого типа. Должно быть тогда runWs возвращает значение этого типа.

Теперь давайте обратимся к runWs, Его аргумент - естественная трансформация f ~> m который в вашем примере принимает вашу алгебру запросов в Aff монада Мы можем записать это и попросить компилятор выяснить остальное для нас:

runWs :: (Query ~> Aff _) -> Aff _ Unit

Это успешно построит и даст вам то, что вы можете заполнить эти дыры. Вот последняя подпись:

runWs :: forall eff. 
      (Query ~> Aff (HalogenEffects 
        ( console :: CONSOLE
        , err :: EXCEPTION
        , ws :: WEBSOCKET
        | eff
        )))
      -> Aff (HalogenEffects
        ( console :: CONSOLE
        , err :: EXCEPTION
        , ws :: WEBSOCKET
        | eff
        )) Unit

Действительно, это именно то, что дает вывод компилятора. Я предполагаю, что сообщение об ошибке "переменная типа a вышла из области видимости" из-за универсального квантификатора в определении естественного преобразования.