unit class Jupyter::Kernel;

use JSON::Tiny;
use Log::Async;
use Net::ZMQ4::Constants;
use UUID;

use Jupyter::Kernel::Service;
use Jupyter::Kernel::Sandbox;
use Jupyter::Kernel::Magics;
use Jupyter::Kernel::Comms;
use Jupyter::Kernel::History;

has $.engine-id = ~UUID.new: :version(4);
has $.kernel-info = {
    status => 'ok',
    protocol_version => '5.0',
    implementation => 'p6-jupyter-kernel',
    implementation_version => '1.0.1',
    language_info => {
        name => 'raku',
        version => ~$*RAKU.version,
        mimetype => 'text/plain',
        file_extension => '.raku',
    },
    banner => "Welcome to Raku 🦋 ({ $*RAKU.compiler.name } { $*RAKU.compiler.version })."
}
has $.magics = Jupyter::Kernel::Magics.new;
has Int $.execution_count = 1;
has $.sandbox;
has $.handler = Jupyter::Kernel::Handler.new;

method resources {
    return %?RESOURCES;
}

method run($spec-file!) {
    info 'starting jupyter kernel';

    my $spec = from-json($spec-file.IO.slurp);
    my $url = "$spec<transport>://$spec<ip>";
    my $key = $spec<key> or die "no key";
    my Jupyter::Kernel::History $history;

    debug "read $spec-file";
    debug "listening on $url";

    sub svc($name, $type) {
        Jupyter::Kernel::Service.new( :$name, :socket-type($type),
                :port($spec{"{ $name }_port"}), :$key, :$url).setup;
    }

    my $ctl   = svc('control', ZMQ_ROUTER);
    my $shell = svc('shell',   ZMQ_ROUTER);
    my $iopub = svc('iopub',   ZMQ_PUB);
    my $hb    = svc('hb',      ZMQ_REP);
    my $iopub_supplier = Supplier.new;
    my $iopub_promise = Promise.new;
    my $sigint = Promise.new;

    start react whenever signal(SIGINT) {
      info "Got sigint";
      $iopub_supplier.emit: ('stream', { :text("Trapped interrupt.  Please restart the kernel to abort execution.\n"), :name<stdout> });
      $sigint.keep;
    }

    method ciao (Bool $restart

False


            # Reset context
            $!handler = Jupyter::Kernel::Handler.new;
            $!sandbox = Jupyter::Kernel::Sandbox.new(:$.handler, :$iopub_supplier);
            $!execution_count = 1;

            $ctl.send: 'shutdown_reply', { :$restart }
            self.register-ciao;
            $iopub_supplier.emit: ('stream', { :text( "Raku kernel restarted\n" ), :name<stdout> });
        } else {
            info "Exiting\n";
            $iopub_supplier.emit: ('stream', { :text( "Exiting Raku kernel (you may close client)\n" ), :name<stdout> });
            $ctl.send: 'shutdown_reply', { :$restart }
            exit;
        }
    }

    method register-ciao {
        my $*CIAO = sub ($restart=0) { self.ciao(so $restart); }
        my $eval-code = q:to/DONE/;
            my &quit := my &QUIT := my &exit := my &EXIT := $*CIAO;
            42;
        DONE
        my $result = $.sandbox.eval($eval-code);
        $iopub_supplier.emit: ('execute_input', { :$eval-code, :execution_count(0), :metadata(Hash.new()) });
    }

    start {
        $hb.start-heartbeat;
    }

    # Control
    start loop {
        my $msg = try $ctl.read-message;
        error "error reading data: $!" if $!;
        debug "ctl got a message: { $msg<header><msg_type> // $msg.raku }";
        given $msg<header><msg_type> {
            when 'shutdown_request' {
                self.ciao($msg<content><restart>);
            }
        }
    }

    # Iostream
    $iopub_supplier.Supply.tap( -> ($tag, %dic) {
        $iopub.send: $tag, %dic;
        try $iopub_promise.break if $tag eq 'status'
            and %dic{'execution_state'} and %dic{'execution_state'} eq 'idle';
    });

    # Shell
    my $promise = start {
    $!sandbox = Jupyter::Kernel::Sandbox.new(:$.handler, :$iopub_supplier);
    self.register-ciao;
    loop {
    try {
        my $msg = $shell.read-message;
        $iopub.parent = $msg;
        $shell.parent = $msg;
        debug "shell got a message: { $msg<header><msg_type> }";
        given $msg<header><msg_type> {
            when 'kernel_info_request' {
                $shell.send: 'kernel_info_reply', $.kernel-info;
                $iopub_supplier.emit: ('status', { :execution_state<idle> });
            }
            when 'execute_request' {
                $iopub_supplier.emit: ('status', { :execution_state<busy> });
                my $code = ~ $msg<content><code>.subst(:g, / \\ $$/, '');
                my $silent = $msg<content><silent>;
                .append($code,:$!execution_count) with $history;
                my $status = 'ok';
                my $magic = $.magics.find-magic($code);
                my $result;
                $result = .preprocess($code) with $magic;
                my $out-mime-type = .?stdout.?mime-type with $magic;
                without $result {
                  my $p = start $.sandbox.eval($code, :store($!execution_count), :$out-mime-type);
                  my $r = await Promise.anyof($p, $sigint);
                  if $sigint {
                    $result = Jupyter::Kernel::Response::Abort.new;
                    $sigint = Promise.new;
                  } else {
                    $result = $p.result;
                  }
                }
                if $magic {
                    with $magic.postprocess(:$code,:$result) -> $new-result {
                        $result = $new-result;
                    }
                }
                my %extra;
                $status = 'error' with $result.exception;
                $iopub_supplier.emit: ('execute_input', { :$code, :$!execution_count, :metadata(Hash.new()) }) unless $silent;
                unless $silent || $result.output-raw === Nil {
                    $iopub_supplier.emit: ('execute_result',
                                { :$!execution_count,
                                :data( $result.output-mime-type => $result.output ),
                                :metadata(Hash.new());
                                });
                }
                # Lock / Send / Unlock
                $iopub_promise = Promise.new;
                $iopub_supplier.emit: ('status', { :execution_state<idle>, });
                # Wait for the iopub to be delivered before reply
                my $content = { :$status, |%extra, :$!execution_count,
                       payload => [], user_expressions => {} }
                # Wait iopub
                await Promise.anyof($iopub_promise, Promise.in(0.2));
                $shell.send: 'execute_reply',
                    $content,
                    :metadata({
                        "dependencies_met" => True,
                        "engine" => $.engine-id,
                        :$status,
                        "started" => ~DateTime.new(now),
                    }) unless $silent;
                $!execution_count++;
            }
            when 'is_complete_request' {
                my $code = ~ $msg<content><code>;
                my $status = 'complete';
                if $code.ends-with('\\') {
                  $status = 'incomplete';
                }
                # invalid?
                debug "sending is_complete_reply: $status";
                $shell.send: 'is_complete_reply', { :$status }
            }
            when 'complete_request' {
                my $code = ~$msg<content><code>;
                my Int:D $cursor_pos = $msg<content><cursor_pos>;
                my (Int:D $cursor_start, Int:D $cursor_end, $completions)
                    = $.sandbox.completions($code,$cursor_pos);
                if $completions {
                    $shell.send: 'complete_reply',
                          { matches => $completions,
                            :$cursor_end,
                            :$cursor_start,
                            metadata => {},
                            status => 'ok'
                    }
                } else {
                    $shell.send: 'complete_reply',
                          { :matches([]), :cursor_end($cursor_pos), :0cursor_start, metadata => {}, :status<ok> }
                }
            }
            when 'shutdown_request' {
                self.ciao($msg<content><restart>);
            }
            when 'history_request' {
                $history = Jupyter::Kernel::History.new.init;
                $shell.send: 'history_reply', { :history($history.read) };
            }
            when 'comm_open' {
                my ($comm_id,$data,$name) = $msg<content><comm_id data target_name>;
                with $.handler.comms.add-comm(:id($comm_id), :$data, :$name) {
                    start react whenever .out -> $data {
                        debug "sending a message from $name";
                        $iopub.send: 'comm_msg', { :$comm_id, :$data }
                    }
                } else {
                    $iopub.send( 'comm_close', {} );
                }
            }
            when 'comm_msg' {
                my ($comm_id, $data) = $msg<content><comm_id data>;
                debug "comm_msg for $comm_id";
                $.handler.comms.send-to-comm(:id($comm_id), :$data);
            }
            when 'comm_info_request' {
                debug "comm_info_request " ~ $msg<content>.raku;
                my $name = $msg<content><target_name>;
                $shell.send: 'comm_info_reply', $.handler.comms.comm-ids;
            }
            default {
                warning "unimplemented message type: $_";
            }
        }
        CATCH {
            error "shell: $_";
            error "trace: { .backtrace.list.map: ~* }";
        }
    }}}
    await $promise;
}


root

README

TestWhatIs

React

=begin React :component<HeaderCol> :id<menu> 
=para L<Documentation|/doc/introduction>
=para L<Modules| /mods>
=para L<Examples| file:../examples/index.podlite>
=para L<Download |file:../download/index.podlite>
=para L<About|file:../about/index.podlite>
=para 🔍 K<⌘K>/K<ctrl-K>
=end React


=begin React :component<HeaderCol> :id<footer>  
=begin nested :!nested
=item1 B<Language>
    =item2 L<Get started|file:../getting-started/getting-started.podlite>
    =item2 L<Why Raku?|/doc/language/faq#Why-should-I-learn-Raku-What's-so-great-about-it>
    =item2 L<Try Raku|https://glot.io/new/raku>
    =item2 L<Raku cheat sheet|https://github.com/Raku/mu/blob/master/docs/Perl6/Cheatsheet/cheatsheet.txt>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<Raku on Exercism|https://exercism.org/tracks/raku>
    =item2 L<Wikipedia|https://en.wikipedia.org/wiki/Raku_(programming_language)>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>

=end nested
=begin nested :!nested

=item1 B<L<Documentation|/doc>>
    =item2 L<Getting started, Migration guides from other languages, & Tutorials | file:../doc/introduction.podlite>
    =item2 L<Language References|file:../doc/reference.podlite>
    =item2 L<Type Reference| file:../doc/types.podlite>
    =item2 L<Miscellaneous| file:../doc/miscellaneous.podlite>
    =item2 L<FAQs (Frequently Asked Questions)|/doc/language/faq>
    =item2 L<Community|/doc/language/community>
    =item2 L<The list of all documents|file:../doc/index.podlite>

=item1 B<Resources>
    =item2 L<The Raku Guide|https://raku.guide/>
    =item2 L<Books |https://perl6book.com/>
    =item2 L<Rosetta Code | https://www.raku.org/community/rosettacode>

=end nested
=begin nested :!nested

=item1 B<Resoures>
    =item2 L<Download | file:../download/index.podlite>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>

=item1 B<Learning>
    =item2 L<The Raku Guide|https://raku.guide/>
    =item2 L<Wikibook |https://en.wikibooks.org/wiki/Raku_Programming>
    =item2 L<Books |https://perl6book.com/>
    =item2 L<Rosetta Code | https://www.raku.org/community/rosettacode>
    =item2 L<Learn Raku in Y minutes|https://learnxinyminutes.com/docs/raku/>
    =item2 L<Golfing |https://github.com/AlexDaniel/raku-golf-cheatsheet>
=end nested
=begin nested :!nested

=item1 B<Explore>
    =item2 L<Raku Blog Aggregator|https://planet.raku.org/>
    =item2 L<Rakudo Weekly|https://rakudoweekly.blog/>
    =item2 L<The Weekly Challenge |https://perlweeklychallenge.org/>
    =item2 L<Raku Advent Calendar|https://raku-advent.blog/>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>

=end nested
=end React


=begin React :component<CookieConsent> :id<CookieConsent> :buttonCaption("Got it!")
=para
This website uses cookies for analytics.
=end React


Kernel

Jupyter::Kernel v1.0.1

Authors

License

Dependencies

Test Dependencies

Provides

Documentation