kkonganti@101: #!/usr/bin/env python
kkonganti@101: 
kkonganti@101: import yaml
kkonganti@101: import platform
kkonganti@101: import subprocess
kkonganti@101: from textwrap import dedent
kkonganti@101: 
kkonganti@101: 
kkonganti@101: def _make_versions_html(versions):
kkonganti@101:     html = [
kkonganti@101:         dedent(
kkonganti@101:             """\\
kkonganti@101:             <link rel="stylesheet" type="text/css" href="https://cdn.datatables.net/v/dt/jszip-2.5.0/dt-1.12.1/b-2.2.3/b-colvis-2.2.3/b-html5-2.2.3/b-print-2.2.3/fc-4.1.0/r-2.3.0/sc-2.0.6/sb-1.3.3/sp-2.0.1/datatables.min.css"/>
kkonganti@101:             <script type="text/javascript" src="https://cdnjs.cloudflare.com/ajax/libs/pdfmake/0.1.36/pdfmake.min.js"></script>
kkonganti@101:             <script type="text/javascript" src="https://cdnjs.cloudflare.com/ajax/libs/pdfmake/0.1.36/vfs_fonts.js"></script>
kkonganti@101:             <script type="text/javascript" src="https://cdn.datatables.net/v/dt/jszip-2.5.0/dt-1.12.1/b-2.2.3/b-colvis-2.2.3/b-html5-2.2.3/b-print-2.2.3/fc-4.1.0/r-2.3.0/sc-2.0.6/sb-1.3.3/sp-2.0.1/datatables.min.js"></script>
kkonganti@101:             <style>
kkonganti@101:             #cpipes-software-versions tbody:nth-child(even) {
kkonganti@101:                 background-color: #f2f2f2;
kkonganti@101:             }
kkonganti@101:             </style>
kkonganti@101:             <table class="table" style="width:100%" id="cpipes-software-versions">
kkonganti@101:                 <thead>
kkonganti@101:                     <tr>
kkonganti@101:                         <th> Process Name </th>
kkonganti@101:                         <th> Software </th>
kkonganti@101:                         <th> Version  </th>
kkonganti@101:                     </tr>
kkonganti@101:                 </thead>
kkonganti@101:             """
kkonganti@101:         )
kkonganti@101:     ]
kkonganti@101:     for process, tmp_versions in sorted(versions.items()):
kkonganti@101:         html.append("<tbody>")
kkonganti@101:         for i, (tool, version) in enumerate(sorted(tmp_versions.items())):
kkonganti@101:             html.append(
kkonganti@101:                 dedent(
kkonganti@101:                     f"""\\
kkonganti@101:                     <tr>
kkonganti@101:                         <td><samp>{process if (i == 0) else ''}</samp></td>
kkonganti@101:                         <td><samp>{tool}</samp></td>
kkonganti@101:                         <td><samp>{version}</samp></td>
kkonganti@101:                     </tr>
kkonganti@101:                     """
kkonganti@101:                 )
kkonganti@101:             )
kkonganti@101:         html.append("</tbody>")
kkonganti@101:     html.append("</table>")
kkonganti@101:     return "\\n".join(html)
kkonganti@101: 
kkonganti@101: 
kkonganti@101: versions_this_module = {}
kkonganti@101: versions_this_module["${task.process}"] = {
kkonganti@101:     "python": platform.python_version(),
kkonganti@101:     "yaml": yaml.__version__,
kkonganti@101: }
kkonganti@101: 
kkonganti@101: with open("$versions") as f:
kkonganti@101:     versions_by_process = yaml.load(f, Loader=yaml.BaseLoader)
kkonganti@101:     versions_by_process.update(versions_this_module)
kkonganti@101: 
kkonganti@101: # aggregate versions by the module name (derived from fully-qualified process name)
kkonganti@101: versions_by_module = {}
kkonganti@101: for process, process_versions in versions_by_process.items():
kkonganti@101:     module = process.split(":")[-1]
kkonganti@101:     try:
kkonganti@101:         assert versions_by_module[module] == process_versions, (
kkonganti@101:             "We assume that software versions are the same between all modules. "
kkonganti@101:             "If you see this error-message it means you discovered an edge-case "
kkonganti@101:             "and should open an issue in nf-core/tools. "
kkonganti@101:         )
kkonganti@101:     except KeyError:
kkonganti@101:         versions_by_module[module] = process_versions
kkonganti@101: 
kkonganti@101: versions_by_module["CPIPES"] = {
kkonganti@101:     "Nextflow": "$workflow.nextflow.version",
kkonganti@101:     "$workflow.manifest.name": "$workflow.manifest.version",
kkonganti@101:     "${params.pipeline}": "${params.workflow_version}"
kkonganti@101: }
kkonganti@101: 
kkonganti@101: versions_mqc = {
kkonganti@101:     "id": "software_versions",
kkonganti@101:     "section_name": "${workflow.manifest.name} Software Versions",
kkonganti@101:     "section_href": "https://cfsan-git.fda.gov/Kranti.Konganti/${workflow.manifest.name.toLowerCase()}",
kkonganti@101:     "plot_type": "html",
kkonganti@101:     "description": "Collected at run time from the software output (STDOUT/STDERR).",
kkonganti@101:     "data": _make_versions_html(versions_by_module),
kkonganti@101: }
kkonganti@101: 
kkonganti@101: with open("software_versions.yml", "w") as f:
kkonganti@101:     yaml.dump(versions_by_module, f, default_flow_style=False)
kkonganti@101: 
kkonganti@101: # print('sed -i -e "' + "s%'%%g" + '" *.yml')
kkonganti@101: subprocess.run('sed -i -e "' + "s%'%%g" + '" software_versions.yml', shell=True)
kkonganti@101: 
kkonganti@101: with open("software_versions_mqc.yml", "w") as f:
kkonganti@101:     yaml.dump(versions_mqc, f, default_flow_style=False)
kkonganti@101: 
kkonganti@101: with open("versions.yml", "w") as f:
kkonganti@101:     yaml.dump(versions_this_module, f, default_flow_style=False)