fortrangoingonforty/fgof-devloop / 687cecd

+

+      - name: Run examples

+        run: fpm run --example --all

+program service_restart_demo

+  use fgof_devloop, only : &

+    FGOF_DEVLOOP_JOB_ACTION_NONE, &

+    FGOF_DEVLOOP_JOB_ACTION_RESTART, &

+    attach_devloop_job, &

+    devloop_change_trigger, &

+    devloop_job_restart_plan, &

+    devloop_service_job, &

+    release_devloop_job

+  use fgof_devloop_types, only : &

+    devloop_job_plan, &

+    devloop_job_spec, &

+    devloop_job_state

+  implicit none

+

+  type(devloop_job_spec) :: spec

+  type(devloop_job_state) :: job

+  type(devloop_job_plan) :: plan

+  type(devloop_job_plan) :: released_plan

+

+  spec = devloop_service_job("serve-example", label="example service")

+  job = attach_devloop_job(spec, pid=4242, process_group=4242)

+  plan = devloop_job_restart_plan(job, devloop_change_trigger(1, "source changed"))

+

+  if (plan%action /= FGOF_DEVLOOP_JOB_ACTION_RESTART) then

+    error stop "running service should plan a restart"

+  end if

+  if (.not. plan%should_stop) error stop "restart plan should stop the old service"

+  if (.not. plan%should_start) error stop "restart plan should start the replacement"

+

+  call release_devloop_job(job)

+  released_plan = devloop_job_restart_plan(job, devloop_change_trigger(1, "after release"))

+  if (released_plan%action /= FGOF_DEVLOOP_JOB_ACTION_NONE) then

+    error stop "released service should no longer be managed"

+  end if

+

+  print '(a,i0)', "managed pid: ", plan%pid

+  print '(a)', "restart reason: " // plan%reason

+  print '(a)', "released reason: " // released_plan%reason

+end program service_restart_demo

+program watch_cycle_demo

+  use fgof_devloop, only : &

+    clear_devloop_options, &

+    devloop_build_command, &

+    devloop_smoke_command, &

+    devloop_summarize_watch_events, &

+    devloop_watch_trigger, &

+    run_devloop_cycle, &

+    start_devloop

+  use fgof_devloop_types, only : &

+    devloop_command_spec, &

+    devloop_options, &

+    devloop_state, &

+    devloop_supervision_result, &

+    devloop_trigger, &

+    devloop_watch_summary

+  use fgof_process, only : &

+    process_options, &

+    shell

+  use fgof_watch_types, only : &

+    FGOF_WATCH_EVT_MODIFIED, &

+    watch_event

+  implicit none

+

+  type(watch_event) :: events(2)

+  type(devloop_options) :: loop_options

+  type(process_options) :: command_options

+  type(devloop_watch_summary) :: summary

+  type(devloop_trigger) :: trigger

+  type(devloop_state) :: state

+  type(devloop_command_spec) :: build

+  type(devloop_command_spec) :: smoke

+  type(devloop_supervision_result) :: supervision

+

+  loop_options = clear_devloop_options()

+  command_options = process_options()

+  command_options%capture_stdout = .true.

+

+  events(1)%kind = FGOF_WATCH_EVT_MODIFIED

+  events(1)%path = "src/app.f90"

+  events(2)%kind = FGOF_WATCH_EVT_MODIFIED

+  events(2)%path = "test/app_test.f90"

+

+  summary = devloop_summarize_watch_events(events)

+  trigger = devloop_watch_trigger(summary, loop_options, "example watch batch")

+

+  call start_devloop(state, loop_options)

+  build = devloop_build_command(shell("printf build-ok"), command_options, "example build")

+  smoke = devloop_smoke_command(shell("printf smoke-ok"), command_options, "example smoke")

+  supervision = run_devloop_cycle(state, trigger, build_command=build, smoke_command=smoke)

+

+  if (.not. supervision%succeeded) error stop "example devloop cycle should succeed"

+  if (supervision%command_count /= 2) error stop "example should run build and smoke"

+

+  print '(a,i0)', "cycle id: ", supervision%cycle%id

+  print '(a,i0)', "changed files: ", supervision%cycle%change_count

+  print '(a)', "build stdout: " // supervision%build%process%stdout

+  print '(a)', "smoke stdout: " // supervision%smoke%process%stdout

+end program watch_cycle_demo

+auto-examples = true