Skip to content

Commit

Permalink
Merge branch 'dev' into feat/runner-stream
Browse files Browse the repository at this point in the history
  • Loading branch information
joschahenningsen committed Feb 7, 2025
2 parents affc656 + 1fe5766 commit 762f95e
Show file tree
Hide file tree
Showing 8 changed files with 16 additions and 10 deletions.
2 changes: 1 addition & 1 deletion .github/workflows/pr-opened-notification.yml
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ jobs:
with:
homeserver: 'matrix.org'
token: ${{ secrets.MATRIX_TOKEN }}
channel: '!LRZZJaApdaBVjDzdpj:in.tum.de'
channel: '!AmOaMEEQgUOTWHlhnA:in.tum.de'
message: |
🫳🎁 Pull request ready for review by ${{ github.event.sender.login }}:
Expand Down
1 change: 0 additions & 1 deletion runner/cmd/runner/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@ func main() {
shouldShutdown := false // set to true once we receive a shutdown signal

currentCount := 0

go func() {
for {
currentCount += <-r.JobCount // count Job start/stop
Expand Down
4 changes: 2 additions & 2 deletions runner/protobuf/notifications.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 2 additions & 2 deletions runner/protobuf/runner.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion runner/protobuf/runner_grpc.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion runner/runner.go
Original file line number Diff line number Diff line change
Expand Up @@ -147,6 +147,7 @@ func (r *Runner) InitApiGrpc() {
r.log.Error("failed to serve", "error", err)
os.Exit(1)
}

}

func (r *Runner) RunAction(a []actions.Action, data map[string]any) string {
Expand Down Expand Up @@ -186,7 +187,6 @@ func (r *Runner) handleNotifications() {
b = retry.WithMaxRetries(10, b)

for n := range r.notifications {
n := n // pin in loop
go func() {
ctx := context.Background()
err := retry.Do(ctx, b, r.sendNotification(n))
Expand Down
3 changes: 1 addition & 2 deletions runner/runner.proto
Original file line number Diff line number Diff line change
Expand Up @@ -39,10 +39,9 @@ message StreamEndRequest {
}

message StreamEndResponse {

}

// RunnerManagerService service defines communication from runners to gocast
// RunnerManagerService service defines communication from runners to gocast
service RunnerManagerService {
// Register is a request to the server to join the runners pool.
rpc Register (RegisterRequest) returns (RegisterResponse) {}
Expand Down
8 changes: 8 additions & 0 deletions web/ts/schedule.ts
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,14 @@ const opts = {
const eventLocation = e.event.extendedProps.location;
if (eventLocation !== null && eventLocation !== undefined && eventLocation !== "") {
e.el.title = e.el.title + " Location: " + eventLocation;
// if stream spans multiple days and therefore item doesn't include start and end time, insert custom start to end
if (e.el.getElementsByClassName("fc-event-time")[0] === undefined) {
const timeElem = document.createElement("div");
timeElem.className = "fc-event-time";
timeElem.innerHTML = "12:00 - 12:00";
const parent = e.el.getElementsByClassName("fc-event-title-container")[0];
parent.insertBefore(timeElem, parent.children[0]);
}
const locationElem = document.createElement("i");
locationElem.innerHTML = "&#183;" + eventLocation;
e.el.getElementsByClassName("fc-event-time")[0].appendChild(locationElem);
Expand Down

0 comments on commit 762f95e

Please sign in to comment.