mirror of
https://github.com/strongdm/comply
synced 2024-08-30 19:03:32 +00:00
50 lines
928 B
Go
50 lines
928 B
Go
|
package render
|
||
|
|
||
|
import (
|
||
|
"sync"
|
||
|
|
||
|
"github.com/pkg/errors"
|
||
|
"github.com/strongdm/comply/internal/model"
|
||
|
)
|
||
|
|
||
|
func pdf(output string, live bool, errCh chan error, wg *sync.WaitGroup) {
|
||
|
var pdfWG sync.WaitGroup
|
||
|
|
||
|
errOutputCh := make(chan error)
|
||
|
|
||
|
for {
|
||
|
_, data, err := loadWithStats()
|
||
|
if err != nil {
|
||
|
errCh <- errors.Wrap(err, "unable to load data")
|
||
|
return
|
||
|
}
|
||
|
|
||
|
policies, err := model.ReadPolicies()
|
||
|
if err != nil {
|
||
|
errCh <- errors.Wrap(err, "unable to read policies")
|
||
|
return
|
||
|
}
|
||
|
for _, policy := range policies {
|
||
|
renderPolicyToDisk(&pdfWG, errOutputCh, data, policy, live)
|
||
|
}
|
||
|
|
||
|
narratives, err := model.ReadNarratives()
|
||
|
if err != nil {
|
||
|
errCh <- errors.Wrap(err, "unable to read narratives")
|
||
|
return
|
||
|
}
|
||
|
|
||
|
for _, narrative := range narratives {
|
||
|
renderNarrativeToDisk(&pdfWG, errOutputCh, data, narrative, live)
|
||
|
}
|
||
|
|
||
|
pdfWG.Wait()
|
||
|
|
||
|
if !live {
|
||
|
wg.Done()
|
||
|
return
|
||
|
}
|
||
|
<-subscribe()
|
||
|
}
|
||
|
}
|