-
Notifications
You must be signed in to change notification settings - Fork 22
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* changing Rye shell to basic ansi colors, so it themable in terminals and works in emacs ansi-term * added testing for failures in various do functions, ssh sever basics * new funcs like nl and pink, ssh integration and example, errors tests starting
- Loading branch information
Showing
14 changed files
with
266 additions
and
23 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,139 @@ | ||
| //go:build b_ssh | ||
| // +build b_ssh | ||
|
|
||
| package evaldo | ||
|
|
||
| import ( | ||
| "io" | ||
|
|
||
| "github.com/gliderlabs/ssh" | ||
| "github.com/jinzhu/copier" | ||
| "github.com/refaktor/rye/env" | ||
| "github.com/refaktor/rye/util" | ||
| ) | ||
|
|
||
| /* | ||
| http-handle "/" fn { w req } { write w "Hello world!" } | ||
| ws-handle "/ws" fn { c } { forever { msg: receive c write c "GOT:" + msg } | ||
| http-serve ":9000" | ||
| new-server ":9000" |with { | ||
| .handle "/" fn { w req } { write w "Hello world!" } , | ||
| .handle-ws "/ws" fn { c } { forever { msg: receive c write c "GOT:" + msg } } , | ||
| .serve | ||
| } | ||
| TODO -- integrate gowabs into this and implement their example first just as handle-ws ... no rye code executed | ||
| if this all works with resetc exits multiple at the same time then implement the callFunction ... but we need to make a local programstate probably | ||
| */ | ||
|
|
||
| var Builtins_ssh = map[string]*env.Builtin{ | ||
|
|
||
| "ssh-server": { | ||
| Argsn: 1, | ||
| Doc: "Create new ssh server.", | ||
| Fn: func(ps *env.ProgramState, arg0 env.Object, arg1 env.Object, arg2 env.Object, arg3 env.Object, arg4 env.Object) env.Object { | ||
| switch addr := arg0.(type) { | ||
| case env.String: | ||
| return *env.NewNative(ps.Idx, &ssh.Server{Addr: addr.Value}, "ssh-server") | ||
| default: | ||
| ps.FailureFlag = true | ||
| return MakeArgError(ps, 1, []env.Type{env.StringType}, "ssh-server") | ||
| } | ||
|
|
||
| }, | ||
| }, | ||
| "ssh-server//handle": { | ||
| Argsn: 2, | ||
| Doc: "HTTP handle function for server.", | ||
| Fn: func(ps *env.ProgramState, arg0 env.Object, arg1 env.Object, arg2 env.Object, arg3 env.Object, arg4 env.Object) env.Object { | ||
| switch server := arg0.(type) { | ||
| case env.Native: | ||
| switch handler := arg1.(type) { | ||
| case env.Function: | ||
| server.Value.(*ssh.Server).Handle(func(s ssh.Session) { | ||
| ps.FailureFlag = false | ||
| ps.ErrorFlag = false | ||
| ps.ReturnFlag = false | ||
| psTemp := env.ProgramState{} | ||
| copier.Copy(&psTemp, &ps) | ||
| CallFunction(handler, ps, *env.NewNative(ps.Idx, s, "ssh-session"), false, nil) | ||
| }) | ||
| return arg0 | ||
| default: | ||
| ps.FailureFlag = true | ||
| return MakeArgError(ps, 2, []env.Type{env.FunctionType}, "ssh-server//handle") | ||
| } | ||
| default: | ||
| ps.FailureFlag = true | ||
| return MakeArgError(ps, 1, []env.Type{env.NativeType}, "ssh-server//handle") | ||
| } | ||
| }, | ||
| }, | ||
| "ssh-server//password-auth": { | ||
| Argsn: 2, | ||
| Doc: "HTTP handler for password authentication.", | ||
| Fn: func(ps *env.ProgramState, arg0 env.Object, arg1 env.Object, arg2 env.Object, arg3 env.Object, arg4 env.Object) env.Object { | ||
| switch server := arg0.(type) { | ||
| case env.Native: | ||
| switch handler := arg1.(type) { | ||
| case env.Function: | ||
| pwda := ssh.PasswordAuth(func(ctx ssh.Context, pass string) bool { | ||
| ps.FailureFlag = false | ||
| ps.ErrorFlag = false | ||
| ps.ReturnFlag = false | ||
| psTemp := env.ProgramState{} | ||
| copier.Copy(&psTemp, &ps) | ||
| newPs := CallFunction(handler, ps, *env.NewString(pass), false, nil) | ||
| return util.IsTruthy(newPs.Res) | ||
| }) | ||
| server.Value.(*ssh.Server).SetOption(pwda) | ||
| return arg0 | ||
| default: | ||
| ps.FailureFlag = true | ||
| return MakeArgError(ps, 2, []env.Type{env.FunctionType}, "ssh-server//handle") | ||
| } | ||
| default: | ||
| ps.FailureFlag = true | ||
| return MakeArgError(ps, 1, []env.Type{env.NativeType}, "ssh-server//handle") | ||
| } | ||
| }, | ||
| }, | ||
| "ssh-server//serve": { | ||
| Argsn: 1, | ||
| Doc: "Listen and serve new server.", | ||
| Fn: func(ps *env.ProgramState, arg0 env.Object, arg1 env.Object, arg2 env.Object, arg3 env.Object, arg4 env.Object) env.Object { | ||
| switch server := arg0.(type) { | ||
| case env.Native: | ||
| server.Value.(*ssh.Server).ListenAndServe() | ||
| return arg0 | ||
| default: | ||
| ps.FailureFlag = true | ||
| return MakeArgError(ps, 1, []env.Type{env.NativeType}, "Go-server//serve") | ||
| } | ||
| }, | ||
| }, | ||
|
|
||
| "ssh-session//write": { | ||
| Argsn: 2, | ||
| Doc: "SSH session write function.", | ||
| Fn: func(ps *env.ProgramState, arg0 env.Object, arg1 env.Object, arg2 env.Object, arg3 env.Object, arg4 env.Object) env.Object { | ||
| switch session := arg0.(type) { | ||
| case env.Native: | ||
| switch val := arg1.(type) { | ||
| case env.String: | ||
| io.WriteString(session.Value.(ssh.Session), val.Value) | ||
| return arg0 | ||
| default: | ||
| ps.FailureFlag = true | ||
| return MakeArgError(ps, 2, []env.Type{env.StringType}, "ssh-session//write") | ||
| } | ||
| default: | ||
| ps.FailureFlag = true | ||
| return MakeArgError(ps, 1, []env.Type{env.NativeType}, "ssh-session//write") | ||
| } | ||
| }, | ||
| }, | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,27 @@ | ||
| //go:build !b_ssh | ||
| // +build !b_ssh | ||
|
|
||
| package evaldo | ||
|
|
||
| import ( | ||
| "github.com/refaktor/rye/env" | ||
| ) | ||
|
|
||
| /* | ||
| http-handle "/" fn { w req } { write w "Hello world!" } | ||
| ws-handle "/ws" fn { c } { forever { msg: receive c write c "GOT:" + msg } | ||
| http-serve ":9000" | ||
| new-server ":9000" |with { | ||
| .handle "/" fn { w req } { write w "Hello world!" } , | ||
| .handle-ws "/ws" fn { c } { forever { msg: receive c write c "GOT:" + msg } } , | ||
| .serve | ||
| } | ||
| TODO -- integrate gowabs into this and implement their example first just as handle-ws ... no rye code executed | ||
| if this all works with resetc exits multiple at the same time then implement the callFunction ... but we need to make a local programstate probably | ||
| */ | ||
|
|
||
| var Builtins_ssh = map[string]*env.Builtin{} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,12 @@ | ||
| rye .needs { http ssh } | ||
|
|
||
| ssh-server ":2222" | ||
| \handle fn { s } { write s pink "I c you :)" .nl } | ||
| \password-auth fn { p } { = "1234" } :ssh | ||
|
|
||
| http-server ":8080" | ||
| \handle "/" fn { w r } { .write "I htttp u" .nl } :http | ||
|
|
||
| go does { serve ssh } go does { serve http } | ||
|
|
||
| select { } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,32 @@ | ||
| section "Runtime error detection" | ||
| "" | ||
| { | ||
| group "do" | ||
| "" | ||
| { { object } } | ||
| { | ||
| error { do { print } } | ||
| error { do { 1 / 0 } } | ||
| } | ||
| group "loop" | ||
| "" | ||
| { { object } } | ||
| { | ||
| error { loop 2 { print } } | ||
| error { loop 2 { 1 / 0 } } | ||
| } | ||
| group "for" | ||
| "" | ||
| { { object } } | ||
| { | ||
| error { for [ 1 2 ] { print } } | ||
| error { for [ 1 2 ] { 1 / 0 } } | ||
| } | ||
| group "with" | ||
| "" | ||
| { { object } } | ||
| { | ||
| error { with { print } } | ||
| error { with { 1 / 0 } } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.