@@ -38,7 +38,6 @@ defmodule Bridge do
3838
3939 """
4040 use GenServer
41-
4241 require Logger
4342
4443 defstruct port: nil ,
@@ -285,8 +284,14 @@ defmodule Bridge do
285284 json = decode! ( json )
286285 payload = json [ :payload ]
287286 pid = json [ :pid ]
288- IO . puts ( "sending event #{ inspect ( payload ) } to #{ inspect ( pid ) } " )
289- send ( pid , payload )
287+ Logger . info ( "sending event #{ inspect ( payload ) } to #{ inspect ( pid ) } " )
288+
289+ if is_pid ( pid ) do
290+ send ( pid , payload )
291+ else
292+ Logger . error ( "Event contains invalid pid: #{ inspect ( json ) } " )
293+ end
294+
290295 { :noreply , state }
291296 end
292297
@@ -348,12 +353,8 @@ defmodule Bridge do
348353 def #{ name } (arg1, arg2, arg3), do: Bridge.bridge_call(:#{ module } , :#{ name } , [arg1, arg2, arg3])
349354 def #{ name } (arg1, arg2, arg3, arg4), do: Bridge.bridge_call(:#{ module } , :#{ name } , [arg1, arg2, arg3, arg4])
350355 def #{ name } (arg1, arg2, arg3, arg4, arg5), do: Bridge.bridge_call(:#{ module } , :#{ name } , [arg1, arg2, arg3, arg4, arg5])
351- def #{ name } (arg1, arg2, arg3, arg4, arg5, arg6), do: Bridge.bridge_call(:#{ module } , :#{
352- name
353- } , [arg1, arg2, arg3, arg4, arg5, arg6])
354- def #{ name } (arg1, arg2, arg3, arg4, arg5, arg6, arg7), do: Bridge.bridge_call(:#{ module } , :#{
355- name
356- } , [arg1, arg2, arg3, arg4, arg5, arg6, arg7])
356+ def #{ name } (arg1, arg2, arg3, arg4, arg5, arg6), do: Bridge.bridge_call(:#{ module } , :#{ name } , [arg1, arg2, arg3, arg4, arg5, arg6])
357+ def #{ name } (arg1, arg2, arg3, arg4, arg5, arg6, arg7), do: Bridge.bridge_call(:#{ module } , :#{ name } , [arg1, arg2, arg3, arg4, arg5, arg6, arg7])
357358 """
358359 end
359360
0 commit comments